如何防止结束消息关闭 Nodejs 流？

Question

在 Node 服务器中，我有一系列管道连接在一起的流。比如说：

streamA.pipe(streamB).pipe(streamC)

最终 streamA 完成，此时我想将下游切换到另一个源：

streamD.pipe(streamB).pipe(streamC)

但是当我尝试这样做时，我收到以下错误：

Error: write after end

如何防止streamA关闭我的下游？或者我怎样才能打开我的下游备份以将它们切换到 streamD？

此外，我的用例要求我等到 streamA 结束。我不能过早地切换流。

Answer 1

一直在谷歌搜索同样的东西，你可以添加

streamA.pipe(streamB, {end: false}).pipe(streamC, {end: false})