JavaScript 中异步管道中错误下发（Error Propagation）怎么在流式数据中传递-js教程-PHP中文网

JavaScript异步流中错误不会自动下发，必须显式捕获并调用controller.error()主动上报；下游需通过catch或error事件监听，否则错误静默终止流。

javascript 中异步管道中错误下发（error propagation）怎么在流式数据中传递

在 JavaScript 的异步流（如 ReadableStream、TransformStream 或 RxJS / Svelte Stores 等流式抽象）中，“错误下发”不是自动穿透的，必须显式处理或封装，否则错误会静默终止流或抛到全局（如未捕获的 promise rejection）。

错误不会自动沿管道向下传递

和同步函数链不同，异步流中的每个阶段（如 transform、map、filter）都是独立的 promise/async 运行上下文。一旦某个环节 throw 或返回 rejected promise，当前 chunk 处理失败，但默认行为是：终止当前流，不通知下游。下游读取器可能永远等不到数据，也收不到明确错误信号。

常见误区：以为 stream.pipeThrough(transform) 会像 try/catch 那样把错误“传下去”。实际它只转发成功值；错误需主动暴露。

正确做法：用 reject + catch 包裹每个异步操作

确保每个流阶段对异常有兜底，让错误变成可观察的信号：

java-api-doc-generator

分析 Java Spring Boot 后端 Controller 代码，自动生成 Markdown 格式的接口文档。当用户说“生成 Java 接口文档”、“生成 API 文档”、“从 Spring 代码生成文档”时触发。

下载

在 transform() 中，用 try/catch 捕获同步异常，并 controller.error(err) 主动报错
对异步操作（如 await fetch()），用 .catch() 捕获 promise rejection，再调用 controller.error()
若使用 ReadableStream.from(AsyncIterable)，需确保 iterable 的 next() 方法抛出的错误能被流捕获（现代浏览器已支持）

下游必须监听 error 事件或使用 await/read() 的 reject 分支

错误下发的终点是消费者——你得主动接住它：

reader.read().catch(err => console.error('流中断:', err))
stream.addEventListener('error', e => ...)（注意：并非所有流都触发此事件，ReadableStream 本身不派发，但 Response.body 等封装流会）
RxJS 中用 catchError 操作符；Svelte Store 中需在 $derived 或订阅回调里处理 promise rejection

进阶：封装带错误透传语义的工具函数

例如写一个安全的 transform 工厂：

function safeTransform(fn) {
  return new TransformStream({
    async transform(chunk, controller) {
      try {
        const result = await fn(chunk);
        controller.enqueue(result);
      } catch (err) {
        controller.error(err); // 关键：主动下发错误
      }
    }
  });
}

// 使用
source.pipeThrough(safeTransform(async x => { throw new Error('boom'); }))
  .getReader()
  .read()
  .catch(e => console.log('捕获到:', e.message)); // ✅ 能收到