何时调用 _read() 的节点可读流

Question

我创建了自己的阅读流。但是我想知道什么时候调用_read（）？ 如果我不添加on('data'）列表器，则不会调用_read（）。为什么？

var data = [{"id":0,"name":"object 0","value":3}],
    Readable = require('stream').Readable,
    util = require('util');
var ReadStream = function() {
    Readable.call(this, {objectMode: true});
    this.data = data;
    this.curIndex = 0;
};
util.inherits(ReadStream, Readable);
ReadStream.prototype._read = function() {
    if (this.curIndex === this.data.length)
        return this.push(null);
    var data = this.data[this.curIndex++];
    //console.log('read: ' + JSON.stringify(data));
    this.push(data);
};

var stream = new ReadStream();
stream.on('data', function(record) {
    console.log('received: ' + JSON.stringify(record));
});
stream.on('end', function() {
    console.log('done111');
});

Answer 1

如果我不添加 on（'data'） listerner，就不会调用 _read（）。为什么？

流已暂停。假设您使用的是最新版本的节点。

https://nodejs.org/api/stream.html#stream_two_modes

所有可读流都以暂停模式开始，但可以通过以下方式之一切换到流动模式：

添加"数据"事件处理程序。

调用 stream.resume（） 方法。

调用 stream.pipe（） 方法将数据发送到可写。

顺便说一句，要创建一个可读的，请检查 noms 或 mississippi.from