nodejs流管道到已经管道的N个流

Question

我想将一个流管道到N个已经管道的流，下面的代码只返回here2，它不进入第一个转换流。似乎管道流的行为不像一个流。

'use strict';
var stream = require('stream');
var through2 = require('through2');
var pass = new stream.PassThrough({objectMode: true});
var transform1 = through2.obj(function(obj, enc, done) {
    console.log('here1');
    this.push(obj);
    done();
}).pipe(through2.obj(function(obj, enc, done) {
    console.log('here2');
    this.push(obj);
    done();
}));
pass.write({'hello': 'world'});
pass.pipe(transform1).on('data', function(data) {
    console.log(data);
});

Answer 1

pipe方法返回目标流。所以transform1流实际上是管道链中的第二流。最终，您只将pass流写入第2流(因此输出始终是'here 2'):试试这个:

pass.pipe(through2.obj(function(obj, enc, done) {
    console.log('here1');
    this.push(obj);
    done();
})).pipe(through2.obj(function(obj, enc, done) {
    console.log('here2');
    this.push(obj);
    done();
}));
pass.write({'hello': 'world'});