。pipe（）之后如何停止流？

Question

const speaker = new Speaker({
          channels: 2,
          bitDepth: 16,
          sampleRate: 44100,
          device: null,
        });

stream.pipe(speaker);

我需要它来播放声音。流是Readable的实例。

Answer 1

stream.pipeline声称可以处理“转发错误并正确清理并在管道完成时提供回调。”

语法

stream.pipeline(...streams, callback)

• …streams：这是两个或多个要通过管道传输在一起的流。
• 回调：当管道完全完成时调用此函数，如果管道未完成，则显示“错误”。

这里是文档的link。