pipeto() 是 web streams api 中将 readablestream 直接连接到 writablestream 的标准方法，性能高、支持背压与错误传播，仅适用于浏览器及现代 node.js 环境，非 java api。
pipeTo() 是 Web Streams API 中用于将 ReadableStream 直接连接到 WritableStream 的标准方法，不经过 JavaScript 层中转，性能高、语义清晰，且原生支持背压（backpressure）和错误传播。
它不是 Java 的 API，而是浏览器和现代 Node.js（v18.19+ / v20.10+ 启用 --experimental-web-streams）环境中的 JavaScript 原生流机制。如果你在 Java 环境中看到类似 pipeTo 的写法，那通常是混淆了概念——Java 没有 pipeTo() 方法，其管道通信依赖 PipedInputStream/PipedOutputStream 等类，且需手动线程协调。
下面聚焦于 正确使用 pipeTo() 的核心要点与实践方式：
pipeTo() 的基本用法
调用形式简洁：readableStream.pipeTo(writableStream)
它返回一个 Promise，在数据全部写入完成或发生错误时 settle。
必须满足的条件
- ReadableStream 必须处于“可读”状态（未被取消、未出错、未关闭）
- WritableStream 必须处于“可写”状态（未被关闭、未出错、未被 abort）
- 两者都需是原生 Web Streams 实例（不能是 Node.js 的
fs.ReadStream或 Java 的PipedInputStream） - 不支持“双向”或“多对一”，一次只能 pipe 到一个 WritableStream
常见终端目标与示例
1. 写入 Response（如 Service Worker 中流式响应）const response = new Response(readableStream);
或更直接地：
await readableStream.pipeTo(response.body.getWriter());（需先获取 writer）
2. 写入 Blob 或文件（通过 WritableStream + createWriteStream）
在支持 WritableStream 的环境（如 Chrome、Firefox、Node.js with web streams）中：
const blobStream = new WritableStream({
write(chunk) { /* 收集 chunk 构建 blob */ },
close() { /* 完成后生成 blob */ }
});
await readableStream.pipeTo(blobStream);
3. 写入 Fetch Request Body（较少见，但可行）
const writable = new WritableStream({ /* 自定义写入逻辑 */ });
await readableStream.pipeTo(writable);
// 后续可将 writable 封装为 ReadableStream 传给 fetch
关键注意事项
- 自动处理背压：当 WritableStream 内部缓冲满时，ReadableStream 会自动暂停拉取数据，无需手动控制
-
错误会传递并 reject Promise：任一流出错，
pipeTo()返回的 Promise 就会 reject；也可用{ preventAbort: true, preventCancel: true, preventClose: true }控制传播行为 -
不可重复调用：一个 ReadableStream 只能 pipeTo 一次；再次调用会抛
InvalidStateError -
不兼容 Node.js 的 fs.createWriteStream()：后者是 legacy stream，需用
stream.pipeline()或转换为 Web Stream（如通过ReadableStream.from()和自定义 writer）
不复杂但容易忽略。
