Node.js.如何將多個流（數組或鏈）傳遞給管道？

Question

我有一個函數返回一個幾個流：

// function 
var s1 = through.obj({highWaterMark: 2}, function(data, enc, next) { 
    console.log("A: "+data); 
    next(null, "A"); 
}); 

var s2 = through.obj({highWaterMark: 2}, function(data, enc, next) { 
    console.log("B: "+data); 
    next(null, "B"); 
}); 

return [s1, s2]; 
// or chain: 
// s1.pipe(s2); 
// return s1; 

我想要的功能，並將結果傳遞到管：

gulp.src(...).pipe(...).pipe(getStreams()).pipe(gulp.dest...); 

有沒有辦法做到這樣？

或者我可以像下一個那樣做一些事情嗎？

​​

Answer 1

我發現幾個方法可以做到這一點。 1）

s1.pipe(s2); 
s1.lastStreamOfChain = s2; 

stream.pipe(s1).lastStreamOfChain.pipe(s3); // Of course it is not good 

2） 使用流combiner2。

combine.obj(s1, s2); 

is there any way to reuse a chain of pipe transformations in NodeJS?

Answer 2

可以使用merge-stream模塊：

const mergeStream = require('merge-stream'); 
gulp.src(...).pipe(...).pipe(mergeStream(s1, s2)).pipe(gulp.dest...);