是什么？
endless-stream是一个用于在Node.js中生成无限流的npm包。它可以从一个可重复调用的函数中获取数据，并包装成无限流，非常适合于处理大量数据或需要持续处理数据的场景。
使用指南
安装
在命令行中输入以下命令安装endless-stream：
npm install endless-stream
导入
在您的JS文件中，使用以下代码导入endless-stream：
const { EndlessStream } = require('endless-stream');创建EndlessStream
使用以下代码创建想要达到无限循环的流：
const endlessStream = new EndlessStream(repeatableFn);
repeatableFn
repeatableFn是一个可重复调用的函数，其中包含可以生成新数据的逻辑。该函数必须返回一个Promise对象。 数据将在每次流被消费时获取。该函数应该始终返回一个Promise，以确保在函数执行完之前不会再次调用。
这是一个简单的例子，其中repeatableFn使用一个随机整数作为数据：
const repeatableFn = async () => {
const randomNumber = Math.floor(Math.random() * 1000);
console.log(`Generating new data: ${randomNumber}`);
return randomNumber;
};消耗EndlessStream
EndlessStream旨在被无限消耗。您可以使用for-await-of循环，或为其注册事件侦听器。 在以下示例中，我们将使用for-await-of循环来消耗EndlessStream。
(async () => {
for await (const data of endlessStream) {
console.log(`Consuming data: ${data}`);
// Do some work with the data
}
})();控制数据传输
可以通过设置数据间隔来控制数据的传输。为此，可以使用frequency选项。这是一个以毫秒为单位表示的时间间隔。在以下示例中，我们设置了数据传输频率为1000毫秒：
const endlessStream = new EndlessStream(repeatableFn, { frequency: 1000 });示例代码
以下是一个完整的示例代码，您可以将其复制到JS文件并运行：
-- -------------------- ---- -------
----- - ------------- - - --------------------------
----- ------------ - ----- -- -- -
----- ------------ - ------------------------ - ------
----------------------- --- ----- ------------------
------ -------------
--
----- ------------- - --- --------------------------- - ---------- ---- ---
------ -- -- -
--- ----- ------ ---- -- -------------- -
---------------------- ----- ----------
-- -- ---- ---- ---- --- ----
-
-----指导意义
通过学习本教程，您将掌握使用endless-stream的方法，从而能够在Node.js中创建无限流并消耗它们。您还将学习如何控制数据的传输，并了解了一个可重复调用的函数的基本原理。这些技能将使您能够在大量数据或需要持续处理数据的场景中高效工作。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60066e25a563576b7b1ece71