Function benchClassic

benchmark/streams/iter-throughput-broadcast.js:34–71

(chunk, numConsumers, datasize, n, totalOps)

}

function benchClassic(chunk, numConsumers, datasize, n, totalOps) {
  function run(cb) {
    const source = new PassThrough();
    const sinks = [];
    let finished = 0;

    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);
    }

    let remaining = datasize;
    function write() {
      let ok = true;
      while (ok && remaining > 0) {
        const size = Math.min(remaining, chunk.length);
        remaining -= size;
        const buf = size === chunk.length ? chunk : chunk.subarray(0, size);
        ok = source.write(buf);
      }
      if (remaining > 0) {
        source.once('drain', write);
      } else {
        source.end();
      }
    }
    write();
  }

  let i = 0;
  bench.start();
  (function next() {
    if (i++ >= n) return bench.end(totalOps);
    run(next);
  })();
}

function benchWebStream(chunk, numConsumers, datasize, n, totalOps) {
  async function run() {