JavaScript异步流中错误不会自动下发，必须显式捕获并调用controller.error()主动上报；下游需通过catch或error事件监听，否则错误静默终止流。
在 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 代码生成文档”时触发。
立即学习“Java免费学习笔记（深入）”；
- 在
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)); // ✅ 能收到 
