传递stream不发射完成事件

我尝试使用through2模块来pipe道一系列传递stream。 最后，我要用Jasmine在unit testing中使用它。

如果我理解正确，省略转换函数将返回一个传递stream。 传递stream是应该发出finish事件的变换stream，对吗？

我在下面的例子中错过了什么？ 我希望它输出fooobar

 var through = require('through2'); through() .pipe(through()) .on('finish', function() { console.log('fooobar'); }); 

node -v v0.12.2 through2 v2.0.0

Answer 1

你的第一个pipe道stream是没有结束的。 尝试这样的事情：

 var through = require('through2'); var stream = through(); stream.pipe(through()) .on('finish', function() { console.log('fooobar'); }); stream.end();