Wait for drain

1const { Writable } = require('node:stream');2const slow = new Writable({3  objectMode: true,4  highWaterMark: 2,5  write(chunk, enc, done) { setTimeout(done, 5); },6});7const items = ['a', 'b', 'c'];8let i = 0;9function writeMore() {10  while (i < items.length) {11    const ok = slow.write(items[i]);12    console.log('wrote ' + items[i++]);13    if (!ok) {14      console.log('pause');15      slow.once('drain', () => { console.log('drain'); writeMore(); });16      return;17    }18  }19  console.log('all written');20}21writeMore();