我需要依次运行两个命令，并且这两个命令都需要从同一流中读取数据。在将一个流导入另一个流之后，缓冲区被清空，所以我无法再从该流中读取数据，因此以下操作不起作用：var spawn = require('child_process').spawn; var fs = require('fs'); ...

我希望将数据从Amazon Kinesis流传输到S3日志或Bunyan日志。 示例使用文件写入流或标准输出。 我该如何实现自己的可写流？//this works var file = fs.createWriteStream('my.log') kinesisSource.pipe(fi...

我该如何将node.js buffer转换为符合stream2接口的可读流？ 我已经找到了这个答案和stream-buffers模块，但该模块基于stream1接口。

目标是： 创建一个文件读取流。 将其传输到gzip (zlib.createGzip())。 然后将zlib输出的读取流传输到： 1) HTTP response对象 2) 和 可写文件流以保存gzipped输出。 现在我可以继续进行到3.1：var gzip = zlib.cre...

我正在尝试对我一个处理流程较为复杂的node-js模块进行单元测试。我试图模拟一个流（我将写入其中），因为我的模块中有“.on('data/end)”监听器，我希望能够触发它们。基本来说，我想要做到这样：var mockedStream = new require('stream').read...

我正在使用一个双工字符串（借助through），将文件通过管道传输，并且我无法同时将信息打印到stdout和写入文件。其中一个可以正常工作。var fs = require('fs'); var path = require('path'); var through = require('th...

根据文档所说，它们都处理将非流插件转换为流插件的问题。我的疑问是，如果我可以在某个东西上使用`.pipe()`方法，这是否意味着它是一个流？如果是这样，我需要将什么转换为什么？vinyl-source-stream示例：（来自：https://www.npmjs.com/package/vin...

如果可能的话，我想将两个Node.js流通过管道合并成一个。我正在使用Transform流。 换句话说，我希望我的库返回myStream供人们使用。例如，他们可以这样写:process.stdin.pipe(myStream).pipe(process.stdout); 我在内部使用一个第三...

我想知道在node.js中是否可能有多个函数可以消耗单个流。如果是的话，应该如何完成？是否可以将其管道传输到多个目标？ 我想在两个不同的并行函数中使用该流。我正在使用async模块进行并行流程。因此，是否可以在这些函数的每个函数内部发出pipe()语句？ 谢谢提前。

我们可以使用 require 函数访问本地模块，但不能通过它访问全局模块。我在某处读到，要使用全局模块，我们需要将其变为本地模块，然后通过 require 函数导入它。那么，如果我们无法直接访问全局模块，那么使用它有什么必要呢？