在Node中生成一个复合流

Make a composite stream in Node

本文关键字:一个 复合 Node      更新时间:2024-06-07

我有几个流想用管道连接

new compositeStream([A,B,C])

我想返回一个单独的流S,其中D.pipe S.pipe E将通过a、B和C输出d,然后通过E输出。

有简单的方法吗?

A.pipe B.pipe C不起作用,因为它只返回目标流。我想要一个在上有入口的新流

作为初步解决方案,pipe-iterators中的.pipeline将执行此操作。

compositePipe = pi.pipeline([A,B,C])

如果有一个更原生的解决方案,那就太好了。

我希望能够像一样连接管道

compositePipe = 
A.pipeline(
B.pipeline(
C)));