Как остановить поток после .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: это два или более потоков, которые должны передаваться вместе.
• callback: эта функция вызывается, когда конвейер полностью завершен, и показывает «ошибку», если конвейер не выполнен .

Вот ссылка на документацию.