Readable转Buffer函数失效：未触发end事件问题排查（node-fetch场景）

核心问题：不必要的Readable.wrap()调用 #

node-fetch在Node.js环境下返回的response.body本身就是标准的Node.js Readable流（Streams 3规范），而Readable.wrap()方法是专门用来适配旧版Streams 1风格的遗留流的。强行用wrap()包装标准Readable流会破坏其内部事件触发逻辑，导致流的end/error事件无法正常触发，最终让你的streamToBuffer Promise永远处于pending状态。

部分ID出现异常的原因是：这些请求对应的响应流被wrap()后内部状态管理混乱——比如流已完成数据传输，但包装后的流未正确转发end事件；或是流传输中出现隐性错误，但包装后的流未触发error事件。而浏览器/curl能正常获取是因为它们直接处理原始响应流，没有经过错误的包装步骤。

修复步骤 #

1. 移除Readable.wrap()包装
   直接返回response.body即可，无需额外包装：

const getBinary = async (id: string) => {
  const response = await fetch(`an internal URL with the id`, { method: 'GET' });
  switch (response.status) {
    case 200:
      return response.body!; // 直接返回原始流
    case 404:
      throw new NotFound(await response.json());
    default:
      throw new BadGateway(await response.json());
  }
};

2. 增强streamToBuffer的鲁棒性（可选）
   为避免极端情况下流事件不触发的问题，可以额外监听close事件作为兜底，同时确保流处于流动模式：

const streamToBuffer = async (stream: NodeJS.ReadableStream): Promise<Buffer> => {
  const chunks: Buffer[] = [];
  return new Promise((resolve, reject) => {
    // 确保流处于流动模式，避免因暂停导致事件不触发
    stream.resume();
    
    stream.on('data', (chunk) => chunks.push(Buffer.from(chunk)));
    stream.on('error', reject);
    stream.on('end', () => resolve(Buffer.concat(chunks)));
    // 兜底逻辑：若流触发close但未触发end，尝试解析已接收的片段
    stream.on('close', () => {
      if (chunks.length > 0) {
        resolve(Buffer.concat(chunks));
      } else {
        reject(new Error('Stream closed without emitting data or end'));
      }
    });
  });
};

3. 验证node-fetch版本
   确保使用最新稳定版的node-fetch（v3+），旧版本可能存在response.body类型不一致的问题，升级后可避免部分隐性流兼容问题。

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