Node.js. Wie man mehrere Ströme (Reihe oder Kette) in Rohr übergibt?

Question

Ich habe eine Funktion, um ein mehr Streams Rückkehr:

// 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; 

ich das Ergebnis der Funktion in der Leitung übergeben mag:

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

Gibt es solche Art und Weise zu tun?

Oder vielleicht kann ich es etwas wie das nächste tun?

var s1 = getStreams(); 
gulp.src(...).pipe(...).pipe(s1) 
s1.getLastStreamOfChain().pipe(gulp.dest...); 

Answer 1

ich ein paar Möglichkeiten, dies zu tun gefunden. 1)

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

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

2) Verwenden der Strom-combiner2.

combine.obj(s1, s2); 

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

Answer 2

Sie können das merge-stream Modul:

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