Function benchIter

benchmark/streams/iter-throughput-compression.js:82–104

(chunk, datasize, n, totalOps)

}

function benchIter(chunk, datasize, n, totalOps) {
  const { pipeTo } = require('stream/iter');
  const { compressGzip, decompressGzip } = require('zlib/iter');

  async function run() {
    let remaining = datasize;
    async function* source() {
      while (remaining > 0) {
        const size = Math.min(remaining, chunk.length);
        remaining -= size;
        yield [size === chunk.length ? chunk : chunk.subarray(0, size)];
      }
    }
    await pipeTo(source(), compressGzip(), decompressGzip(),
                 { write() {}, writeSync() { return true; } });
  }

  (async () => {
    bench.start();
    for (let i = 0; i < n; i++) await run();
    bench.end(totalOps);
  })();
}