Node.js中AbortController在Pipeline的行为差异：是Bug还是预期？

这是Node.js v16版本的预期行为，并非Bug，核心原因在于Transform.from创建的流与pipeline直接包装的异步生成器流，在异常传播机制上存在差异：

1. 两种转换逻辑的本质区别 #

• 第一段代码中，直接将异步生成器函数传给pipeline，pipeline内部会把它包装成一个特殊的转换流，并统一接管这个流的异常处理，所有异常会被冒泡到pipeline返回的Promise中，因此外层的try/catch可以正常捕获中止信号引发的异常。
• 第二段代码用Transform.from创建了标准的Transform流实例，这类流的异常默认会以'error'事件的形式触发。在Node.js v16中，pipeline不会自动捕获这类标准流的'error'事件并传递到Promise链中，如果没有手动监听'error'事件，Node.js会将其视为未捕获异常，直接终止程序，绕过外层的try/catch。

2. AbortController触发后的异常走向 #

当ac.abort()执行时，pipeline会尝试中止所有参与的流：

• 对于pipeline内部包装的异步生成器流，中止信号会被转化为Promise的拒绝，被外层try/catch捕获。
• 对于Transform.from创建的标准流，中止操作引发的异常会触发流的'error'事件，由于v16的pipeline未处理这个事件，导致异常逃逸，程序直接崩溃。

3. 解决方法 #

方法一：手动监听Transform流的error事件 #

给Transform.from创建的流添加error事件监听，将异常重新导向pipeline的上下文：

const transformStream = Transform.from(
  async function* (iter) {
    for await (const value of iter) {
      console.log(`Transform ${value}`);
      yield `${value}${value}`;
    }
  },
);
// 手动监听error事件，将异常传递给pipeline的中止逻辑
transformStream.on('error', (err) => {
  ac.abort(err);
});

// 然后将transformStream传入pipeline
await pipeline(
  readableStream,
  transformStream,
  // 后续流和配置
);

方法二：升级Node.js版本 #

Node.js v18及以上版本修复了这个问题，pipeline会正确捕获Transform.from创建的流的异常，并将其传递到Promise链中，此时外层的try/catch可以正常捕获中止引发的异常，无需额外处理。

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