Function main

benchmark/streams/iter-throughput-broadcast.js:20–32

({ api, consumers, datasize, n })

const CHUNK_SIZE = 64 * 1024;

function main({ api, consumers, datasize, n }) {
  const chunk = Buffer.alloc(CHUNK_SIZE, 'abcdefghij');
  const totalOps = (datasize * n) / (1024 * 1024);

  switch (api) {
    case 'classic':
      return benchClassic(chunk, consumers, datasize, n, totalOps);
    case 'webstream':
      return benchWebStream(chunk, consumers, datasize, n, totalOps);
    case 'iter':
      return benchIter(chunk, consumers, datasize, n, totalOps);
  }
}

function benchClassic(chunk, numConsumers, datasize, n, totalOps) {
  function run(cb) {