先记住这个答案
pipe 连接可读流与可写流并处理常见背压，但不能把它理解为自动完成整条链所有错误传播与资源销毁。pipeline 把多个阶段作为一项操作管理，提供完成回调或 Promise，并在错误时按流的状态与契约销毁参与流，适合文件、转换和写入等处理链。它仍不负责流外的临时文件或业务回滚；若目的地是 HTTP 响应，失败时响应或 socket 可能已经被销毁，不能在 catch 中无条件再发送一份错误页面。
- pipe 有背压能力，但整链错误管理需额外设计
- pipeline 提供整项操作的完成与失败结果
- 流外资源和 HTTP 错误响应需要单独安排
pipe 不是没有背压，而是完成责任较局部
单次 pipe 可以根据下游写入压力暂停或恢复上游，这一点不能忽略。但源流出错不等于所有目的流都会按业务需要自动关闭，多个阶段还需要统一处理错误、提前关闭和最终成功。
手动连接并非一定错误，只是调用方要承担完整生命周期设计。若各阶段都由当前任务拥有，pipeline 通常更容易表达一项从源到目的地的操作；若资源被共享，则要先明确能否允许整链失败时销毁它们。
用 Promise 结果收敛整条转换链
示例只接受对象模式中的字符串记录，把它们转成大写后交给目的地。遇到其他类型时通过转换回调报告错误，让 pipeline 拒绝并处理参与流，而不是在回调里直接抛异常或悄悄丢掉坏数据。
这里每个输入已经是一条完整字符串记录，因此不会把任意字节 chunk 的边界当作文本记录边界。真实文件或网络文本需要先正确解码和分帧，再进行记录级转换；流连接工具不会自动推导业务协议。
import { Readable, Transform, Writable } from 'node:stream';
import { pipeline } from 'node:stream/promises';
export async function uppercaseRecords(source: Readable, destination: Writable) {
const transform = new Transform({
objectMode: true,
transform(value, _encoding, callback) {
if (typeof value !== 'string') {
callback(new TypeError('string records required'));
return;
}
callback(null, value.toUpperCase());
}
});
await pipeline(source, transform, destination);
}调用方提供对象模式来源和可接收字符串记录的目的流。测试分别输入全是字符串的序列与包含数字的序列，检查完整成功结果和失败后的参与流状态，不把已写出的前缀当作成功产物。
HTTP 响应与流外资源有额外边界
文件读取、压缩和 HTTP 响应放进 pipeline 后，中途失败可能让响应被销毁，此时 catch 再调用 res.end 输出错误正文未必可行。应在开始传输前完成必要校验，发送后发生错误则按连接和响应状态记录或结束。
pipeline 不会删除应用另外创建的临时文件，也不会回滚已提交的数据库状态。应在任务级 finally 或明确补偿流程中处理流外资源，并让自定义流的销毁实现真正释放它持有的句柄，避免只关闭接口却留下底层工作。
容易答错的地方
- 认为 pipe 会自动回收所有中间阶段
- 它主要提供连接和相关流动控制，完整链路的错误传播与所有权仍需设计。若没有统一收尾，某个阶段失败后其他流可能继续持有资源；应使用合适的整链工具或明确补齐管理逻辑。
- 在 pipeline 的 catch 里无条件补写 HTTP 错误页
- 响应或 socket 可能已被销毁，也可能已经发送了部分正文和头部。应在可发送之前确定状态，传输中失败后按实际连接状态处理，不能承诺任何阶段都能改成一份完整的新错误响应。
面试官还会怎么问？
pipeline 已经销毁流，为什么还可能有资源问题？
自定义流的销毁实现可能没有正确释放外部句柄，或者应用在流外另开了文件、请求和任务。应检查真正的资源所有者与清理回调，不能把接口层的 destroyed 标志当成全部业务资源已结束。
pipeline 失败后可以复用原来的流重试吗？
通常应为新尝试创建新流，失败对象可能已销毁且保留部分监听或内部状态。重试还需要处理已经写出的部分产物与幂等，不能只把同一个对象再次传入函数就期待恢复到初始状态。
需要保留目的流不结束时怎么办？
先确认所用版本和接口支持的结束控制，并明确谁在以后负责结束目的地。缩小 pipeline 的所有权可能改变完成语义，不能为了复用共享资源随意忽略错误或让上游任务误以为整个目的地已完成。
参考资料
示例用于理解所注明的运行环境与边界；延伸学习可结合原文中的更多案例。