节点 - piping process.stdout不会自动排空。

Question

考虑这个Readable流。

class ReadableStream extends stream.Readable {
  constructor() {
    super({objectMode:true, highWaterMark:128});
  }

  i = 0;
  _read(size: number) {
    while (this.push({key:this.i++})){}
  }
}

输送到process.stdout的管道并没有自动排空它 什么也没发生，程序就会退出。

new ReadableStream().pipe(process.stdout);

现在，让我们用管道把它转到这个可写流。

class WritableStream extends stream.Writable {
  constructor() {
    super({objectMode:true, highWaterMark:128});
  }

  _write(chunk: any, encoding: string, callback: (error?: (Error | null)) => void) {
    console.log(chunk);
    callback();
  }
}

new ReadableStream().pipe(new WritableStream());

控制台马上就被数字填满了 所以它就会进入无穷大的状态

为什么process.stdout或fs.createWriteStream会自动请求数据？

Answer 1

process.stdout 不是一个对象模式的流，当你把一个对象模式的流管到它身上时，它不能正常工作。 如果你把你的readableStream改成不是对象模式流，那么你的 .pipe() 将会正常工作。

事实上，如果您为 error 事件，如。

new ReadableStream().pipe(process.stdout).on('error', err => {
    console.log(err);
});

然后，你会得到这个

TypeError [ERR_INVALID_ARG_TYPE]: The "chunk" argument must be one of type string or Buffer. Received type object
    at validChunk (_stream_writable.js:268:10)
    at WriteStream.Writable.write (_stream_writable.js:303:21)
    at ReadableStream.ondata (_stream_readable.js:727:22)
    at ReadableStream.emit (events.js:210:5)
    at ReadableStream.Readable.read (_stream_readable.js:525:10)
    at flow (_stream_readable.js:1000:34)
    at resume_ (_stream_readable.js:981:3)
    at processTicksAndRejections (internal/process/task_queues.js:80:21) {
  code: 'ERR_INVALID_ARG_TYPE'
}

这说明stdout没有期望得到一个对象。