疑问来自这里
//可读流在接收者没有读取数据之前,会缓存所有压入的数据
var Readable = require('stream').Readable;
var rs = new Readable;
rs.push('beep ');
rs.push('boop\n');
rs.push(null);
rs.pipe(process.stdout);
//通过重写_read()方法实现了只有在数据接受者请求数据才向可读流中压入数据
var Readable = require('stream').Readable;
var rs = Readable();
var c = 97;
rs._read = function () {
rs.push(String.fromCharCode(c++));
if (c > 'z'.charCodeAt(0)) rs.push(null);
};
rs.pipe(process.stdout);
通过重写_read()方法实现了只有在数据接受者请求数据才向可读流中压入数据,这段话不是很明白。
原来理解是 read.on 'data'之后主动往writeStream里写数据,那这里说的writeStream请求数据是怎么回事呢?是如何请求的呢?
