Node Backpressure Aware Copy

index.js

function backpressureAwareCopy(srcStream, destStream) {
  srcStream.on('data', (chunk) => {
    const canContinue = destStream.write(chunk);
    if (!canContinue) {
      // if we are overflowing the destination, we stop reading
      srcStream.pause();
      // once all the buffered data is flushed, we resume reading from source
      destStream.once('drain', () => srcStream.resume());
    }
  })
}