Node.js 的 stream/promises.pipeline 在处理异步生成器链时，若末尾函数仍使用 yield 输出数据但无消费者接收，会导致背压累积、流挂起，从而在约 30 项后静默中断——这是典型的未消费数据引发的内部缓冲区阻塞。
node.js 的 `stream/promises.pipeline` 在处理异步生成器链时，若末尾函数仍使用 `yield` 输出数据但无消费者接收，会导致背压累积、流挂起，从而在约 30 项后静默中断——这是典型的未消费数据引发的内部缓冲区阻塞。
在使用 pipeline(func, func2, func3) 构建异步流处理链时，pipeline 会自动将前一个阶段的输出作为下一个阶段的输入，并期望最后一个阶段是“终点”（PipelineDestination）：它应消费所有上游数据，但不应再产出可被进一步消费的流。而你的原始代码中，func3 仍为 async function* 并执行 yield i，这使其成为了一个可迭代的源（AsyncIterable）而非终结者。
Node.js 流实现（尤其是 stream/promises.pipeline 底层使用的 readable-stream v4+）会对未被消费的 yield 值进行内部缓冲。当缓冲区填满（默认高水位线 highWaterMark: 32，实际有效缓冲常约为 30–32 项），上游生成器（如 func2）将因背压暂停 yield，最终整个 pipeline 静默卡住——无报错、无拒绝，仅停止推进。
✅ 正确做法是：将最终处理函数改为普通 async function（非生成器），或保留 async function* 但移除 yield，确保其只消费、不产出：
// ✅ 推荐：明确语义 —— func3 是终点，只消费
async function func3(iterator: AsyncIterable<number>) {
for await (const i of iterator) {
console.log(`func3 ${i}`);
// 不 yield → 数据在此终止，无下游等待
}
}
// 或保持生成器语法但不产出（等效，但语义稍弱）
async function* func3(iterator: AsyncIterable<number>) {
for await (const i of iterator) {
console.log(`func3 ${i}`);
// 无 yield → 此生成器为空流，pipeline 自动识别为 sink
}
}⚠️ 注意事项：
-
pipeline要求链中至多一个AsyncIterable作为源（第一个参数），其余中间转换函数应为AsyncIterable<t> => AsyncIterable<r></r></t>，而最后一个必须是AsyncIterable<t> => Promise<void></void></t>或等效终结行为； - 切勿在终点函数中
yield或返回新AsyncIterable，否则 pipeline 无法判断流是否结束； - 若需将结果收集为数组，应在终点显式
push到数组并await完成，而非依赖yield传递； - 调试技巧：在各阶段
console.log前添加process.stdout.write('')强制刷新，避免日志缓冲掩盖挂起现象。
总结：pipeline 的健壮性高度依赖各阶段角色清晰——源（source）、转换（transform）、终点（sink）。混淆 sink 与 transform 的产出行为，是导致静默中断的最常见原因。遵循“终点不产出”原则，即可彻底规避此类问题。
