Function run

benchmark/streams/compose.js:69–96

()

  bench.start();

  function run() {
    if (i++ === n) {
      bench.end(n * chunks);
      return;
    }

    const passThroughs = [];
    for (let i = 0; i < numberOfPassThroughs; i++) {
      passThroughs.push(new PassThrough());
    }

    let remaining = chunks;
    const composed = compose(...passThroughs);
    composed.on('data', () => {});
    composed.on('end', run);

    write();

    function write() {
      while (remaining-- > 0) {
        if (!composed.write(chunk)) {
          composed.once('drain', write);
          return;
        }
      }
      composed.end();
    }
  }

  run();
}