Function benchIterSync

benchmark/streams/iter-throughput-transform.js:125–146

(chunk, datasize, n, totalOps)

}

function benchIterSync(chunk, datasize, n, totalOps) {
  const { pipeToSync } = require('stream/iter');

  const upper = (chunks) => {
    if (chunks === null) return null;
    return chunks.map((c) => copyBuf(c));
  };

  bench.start();
  for (let i = 0; i < n; i++) {
    let remaining = datasize;
    function* source() {
      while (remaining > 0) {
        const size = Math.min(remaining, chunk.length);
        remaining -= size;
        yield [size === chunk.length ? chunk : chunk.subarray(0, size)];
      }
    }
    pipeToSync(source(), upper, { writeSync() {} });
  }
  bench.end(totalOps);
}