节点 - 管道 process.stdout 不会自动排空答案

【问题标题】：Node - piping process.stdout doesn't drain automatically节点 - 管道 process.stdout 不会自动排空
【发布时间】：2020-09-03 11:09:14
【问题描述】：

考虑这个可读流：

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);

现在，让我们将其通过管道传递给这个 Writable 流：

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 会自动请求数据？

【问题讨论】：

你没有在 objectMode 下尝试过吗？
@jfriend00 真的！现在工作。谢谢。
process.stdout 不是 objectMode 流，所以我猜它不知道当你通过管道传输它时该怎么做。

标签： node.js stream node-streams nodejs-stream

【解决方案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 不期望得到一个对象。

【讨论】：

@JohnSmith - 查看我在答案末尾添加的内容。如有疑问，请始终添加适当的错误侦听器，它通常会提供有关正在发生的事情的提示。