NodeJS Stream pipeline无提示崩溃问题求助（附复现代码）

你的自定义Readable流_read方法违反了Node.js流的核心规范：

• _read会被流的内部机制反复调用，直到缓冲区填满或流被结束
• 当前代码中，当_rowsToSend为空后，每次_read触发都会执行this.push(null)，而重复调用push(null)是非法操作，这会触发流内部未捕获错误，直接导致进程无提示崩溃

给自定义Readable流添加结束标记，确保仅调用一次push(null)来终止流：

修改后的Stream类代码：

class Stream extends Readable {
  constructor(options) {
    super(options);
    this._rowsToSend = [];
    this._streamEnded = false; // 添加流结束标记
    const nbRows = 100;
    for (let i = 0; i < nbRows; ++i) {
      this._rowsToSend.push(`row n°${i + 1}/${nbRows}`);
    }
    this.on("error", (error) => {
      console.log("STREAM ERROR", error);
    });
  }

  _read(size) {
    if (this._streamEnded) return; // 已结束则直接返回，避免重复触发结束逻辑
    const row = this._rowsToSend.shift();
    if (row) {
      console.log(`SENDING: ${row}`);
      this.push(this.readableObjectMode ? row : Buffer.from(JSON.stringify(row), this.readableEncoding || undefined));
    }
    else {
      console.log(`END OF STREAM`);
      this._streamEnded = true; // 标记流已结束
      this.push(null);
    }
  }

  _destroy(error, callback) {
    this._rowsToSend = [];
    this._streamEnded = true; // 销毁时同步标记结束
    console.log("STREAM DESTROYED");
    callback(error);
  }
}

修改后，流只会在首次耗尽数据时调用push(null)，后续_read调用会直接跳过结束逻辑，完全符合Node.js流规范。运行代码会正常输出所有数据行、END OF STREAM、TRANSFORM FLUSHED和SUCCESS，不会再出现无提示崩溃。

额外优化提示：Node.js流的_read设计初衷是按需处理背压，每次调用时可根据push返回值判断是否暂停推送（返回false时应停止，等待drain事件后再继续），但这属于性能优化，并非本次崩溃的直接原因。

内容的提问来源于stack exchange，提问作者theofarus