Streams 管道错误传播与恢复机制

`title: Streams 管道错误传播与恢复机制``categories: Web 开发/前端/数据管理``keywords: Streams,错误传播,pipeThrough,pipeTo,恢复``description: 解析 Streams 管道中的错误传播机制与关闭语义，设计重试与恢复策略，保障持久化与实时处理的稳定性。`错误处理在 `pipeThrough` 的 Transform 中捕获并选择性传播；`pipeTo` 返回的 promise 用于统一失败处理。示例const transform = new TransformStream({

transform(chunk, controller) {

if (!chunk) throw new Error('invalid');

controller.enqueue(chunk);

}

});

async function process(src, writable) {

try {

await src.pipeThrough(transform).pipeTo(writable);

} catch (e) {

// 恢复策略：重新创建管道或回退到缓冲写入

}

}