如何为Node.js Stream添加延迟Pipe且不丢失数据？

核心机制：readable 事件触发后的流状态变化 #

当你为流添加 readable 事件监听器时，流会自动切换到暂停模式（paused mode）。在这种模式下，数据会被缓冲在流内部，但流不会主动推送数据，除非你显式调用 .read() 方法，或者通过 pipe()、监听 data 事件等方式切换回流动模式（flowing mode）。

第一个示例的问题流程拆解 #

1. 为 input 流绑定 readable 监听器，流进入暂停模式。
2. 1秒后调用 input.write() 写入数据，数据被缓冲到 input 内部，触发 readable 事件。
3. 进入 readable 回调函数后调用 input.pipe(output)：此时 pipe() 确实建立了两个流的连接，但当前已缓冲的数据不会被自动推送——因为 readable 事件的触发是基于"已有数据待读取"的状态，而 pipe() 是在这个事件的回调里才完成绑定，流不会在这个事件周期内主动把已缓冲的数据发送给目标流。由于之后没有新的数据写入，缓冲的数据就永远留在 input 里，不会到达 output。

第二个示例正常工作的原因 #

第二个示例中，input.write() 先执行，数据被缓冲，之后在独立的 setTimeout 回调里执行 pipe()：

• pipe() 建立连接时，会自动触发流切换到流动模式，同时主动读取 input 中已缓冲的数据，并推送给 output。
• 这个流程没有被 readable 事件的回调打断，pipe() 可以正常触发流的缓冲数据读取逻辑。

修复第一个示例的方法 #

如果一定要在 readable 事件内执行 pipe()，可以在绑定后手动调用一次 .read() 来触发已缓冲数据的流动：

input.on("readable", () => {
    console.log("input is readable, pipe to output");
    input.pipe(output);
    // 手动读取一次，触发已缓冲数据的推送
    input.read();
});

或者，避免在 readable 事件回调内执行 pipe()，改为在需要延迟的时机（比如外部的定时器）直接绑定，就像第二个示例那样。

内容的提问来源于stack exchange，提问作者Marc