pull-stream

pull-stream

最小可管道拉流 在 classic-streams 中, 流将数据推送到管道中的下一个流。 在 新流 中, 数据从源流中提取到目的地。 pull-stream 是对流的最小化实现, 对"对象"流以及原始文本或二进制数据的流,拉取流都表现得非常好。

简单示例

统计某些文件:

pull(
  pull.values(['file1', 'file2', 'file3']),
  pull.asyncMap(fs.stat),
  pull.collect(function (err, array) {
    console.log(array)
  })
)

请注意,pull(a, b, c) 基本上与 a.pipe(b).pipe(c) 相同。 要了解拉取流如何工作,请阅读 拉取流研讨会

如何使用拉流式传输来执行 X 操作?

为此已经有了一个模块!

请查看 pull-stream 常见问题，如果您有未涵盖的问题，请发布问题。

另请参阅:

• 源代码
• 通过
• 池

源 (生成值的可读流)

源是一个函数 read(end, cb), 可以多次调用 并且会 (异步) 为每个调用一次调用 cb(null, data)。 为了表示终止状态,流最终会返回 cb(err) 或 cb(true)。 当表示终止状态时,data 必须 被忽略。 read 函数 *必须 n

pull-stream-to-stream