Function run

benchmark/streams/iter-throughput-transform.js:42–59

(cb)

function benchClassic(chunk, datasize, n, totalOps) {
  function run(cb) {
    let remaining = datasize;
    const r = new Readable({
      read() {
        if (remaining <= 0) { this.push(null); return; }
        const size = Math.min(remaining, chunk.length);
        remaining -= size;
        this.push(size === chunk.length ? chunk : chunk.subarray(0, size));
      },
    });
    const t = new Transform({
      transform(data, enc, cb) {
        cb(null, copyBuf(data));
      },
    });
    const w = new Writable({ write(data, enc, cb) { cb(); } });
    pipeline(r, t, w, cb);
  }

  let i = 0;
  bench.start();