使用可写流作为事件发射器

Question

我想知道是否可以使用可写流 (require('stream').Writable) 作为事件发射器。

例如，

   var jsonData = [];

   var strm = new stream.Writable({
        write: function(chunk, encoding, next) {

            jsonData.push(chunk.toString());
            next();
        }

    });


    strm.on('foo',function(msg){
        console.log(msg); //doesn't get called
    });

    strm.emit('foo','bar');  //this doesn't seem to do anything

我认为可读/可写流是事件发射器，但我似乎不能真正以这种方式使用它们？还想知道我是否通过写入 Writable 对象/流之外的数组来正确使用 Writable。

Answer 1

Streams 确实是事件发射器，您的代码示例在节点 v4.2.4 上运行良好

vladmiller:tmp vladmiller$ node test.js
bar

和节点v0.12.7

vladmiller:tmp vladmiller$ node test.js
bar