节点 - 管道 process.stdout 不会自动排水

Question

考虑这个可读流：

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 不期望获得对象。

节点 - 管道 process.stdout 不会自动排水

Node - piping process.stdout doesn't drain automatically

stream

node.js

node-streams

nodejs-stream