Node.js PassThrough流写入结束后如何读取数据？

你的代码挂起的核心原因是：调用stream.end()后，流的end事件已经触发，但此时你还未添加任何事件监听器。后续再绑定data和end监听器时，这些事件早已触发完毕，导致Promise永远无法resolve，代码陷入挂起状态。

以下是两种可行的解决方案：

方案一：手动读取缓冲区数据 #

PassThrough流会将写入的数据暂存到内部缓冲区，即便流已经结束，依然可以通过stream.read()手动取出所有数据：

import { PassThrough } from 'stream';

const stream = new PassThrough();
stream.write('Test chunk.');
stream.end();

// 后续读取逻辑
const chunks: Buffer[] = [];
let chunk: Buffer | null;
while ((chunk = stream.read()) !== null) {
  chunks.push(chunk);
}
const output = Buffer.concat(chunks);
console.log(output.toString()); // 输出 "Test chunk."

方案二：兼容事件监听的处理方式 #

如果你更倾向于使用事件监听模式，可以先检查流是否已经结束，提前处理缓冲区数据，再决定是否绑定事件：

import { PassThrough } from 'stream';

const stream = new PassThrough();
stream.write('Test chunk.');
stream.end();

// 后续读取逻辑
const output = await new Promise<Buffer>((resolve, reject) => {
  const chunks: Buffer[] = [];

  // 先读取缓冲区中已有的数据
  let chunk: Buffer | null;
  while ((chunk = stream.read()) !== null) {
    chunks.push(chunk);
  }

  // 如果流已经结束，直接返回结果
  if (stream.readableEnded) {
    resolve(Buffer.concat(chunks));
    return;
  }

  // 流未结束时，正常监听事件
  stream.on('data', (chunk) => chunks.push(Buffer.from(chunk)));
  stream.on('error', reject);
  stream.on('end', () => resolve(Buffer.concat(chunks)));
});

console.log(output.toString()); // 输出 "Test chunk."

需要说明的是：PassThrough确实实现了可读端与可写端的解耦，但它的事件触发是一次性的——end事件在stream.end()调用后会立即触发，若后续才绑定监听器，就无法捕获该事件。因此必须优先处理缓冲区数据，再结合流的状态判断来完成读取。

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