Function write

benchmark/streams/iter-throughput-broadcast.js:41–41

(data, enc, cb)

    for (let c = 0; c < numConsumers; c++) {
      const w = new Writable({ write(data, enc, cb) { cb(); } });
      source.pipe(w);
      w.on('finish', () => { if (++finished === numConsumers) cb(); });
      sinks.push(w);