Function benchFromSyncWritev

benchmark/streams/iter-from-batching.js:69–100

(chunks, chunkSize, n)

}

function benchFromSyncWritev(chunks, chunkSize, n) {
  const { pipeToSync } = require('stream/iter');
  const chunk = new Uint8Array(chunkSize);
  const expected = chunks * chunkSize * n;
  let seen = 0;
  let total = 0;
  const fd = openSync(devNull, 'w');
  const writer = {
    writeSync(chunk) {
      writeSync(fd, chunk);
      seen++;
    },
    writevSync(batch) {
      writevSync(fd, batch);
      seen += batch.length;
    },
  };

  try {
    bench.start();
    for (let i = 0; i < n; i++) {
      total += pipeToSync(source(chunks, chunk), writer);
    }
    bench.end(chunks * n);
  } finally {
    closeSync(fd);
  }

  if (total !== expected || seen !== chunks * n) {
    throw new Error('unexpected chunk count');
  }
}