Function asyncWriteToStream

A small utility function for writing chunk to a stream, and only return promise when needed (stream backpressure)

const writeStream = fs.createWriteStream(outputFile);
for (const line of source) {
  const p = asyncWriteToStream(writeStream, line + '\n');
  if (p) {
    // eslint-disable-next-line no-await-in-loop -- stream backpressure
    await p;
  }

Copy