如何在 .pipe() 之后停止流？

Question

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

stream.pipe(speaker);

我需要它来中断播放声音。 Stream 是 Readable 的实例。

Answer 1

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

语法

stream.pipeline(...streams, callback)

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

这是一个link 文档。