流（Stream）

[coxo]

流（Stream）是可读，可写或双工的。

可以通过require('stream')加载流的基类，其中包括四类流，

• Readable 流
• Writable 流
• Duplex 流
• Transform流的基类

另外如果觉得上述四类基类流不能满足需求，可以编写自己的扩充类流。
像我的BearStream。

[coxo]

SimpleProtocol.prototype = Object.create(
 //SimpleProtocol继承readable类
  Readable.prototype, { constructor: { value: SimpleProtocol }}
);

[daxiongjun]

补充个板栗

自定义readable stream的实现

var Stream = require('stream');
var Read = Stream.Readable;
var util = require('util');

util.inherits(MyReadStream, Read);

function MyReadStream(data, opt) {
    Read.call(this, opt);
    this.data = data || [];
}
MyReadStream.prototype._read = function () {
    var _this = this;
    this.data.forEach(function (d) {
        _this.push(d);
    })
    this.push(null);
}

var data = ['aa', 'bb', 'cc'];
var r = new MyReadStream(data);

r.on('data', function (chunk) {
    console.log(chunk.toString());
})

[VaJoy]

@daxiongjun 大熊去学markdown怎么用