Function main

benchmark/webstreams/pipe-to.js:15–36

({ n, highWaterMarkR, highWaterMarkW })

async function main({ n, highWaterMarkR, highWaterMarkW }) {
  const b = Buffer.alloc(1024);
  let i = 0;
  const rs = new ReadableStream({
    highWaterMark: highWaterMarkR,
    pull: function(controller) {
      if (i++ < n) {
        controller.enqueue(b);
      } else {
        controller.close();
      }
    },
  });
  const ws = new WritableStream({
    highWaterMark: highWaterMarkW,
    write(chunk, controller) {},
    close() { bench.end(n); },
  });

  bench.start();
  rs.pipeTo(ws);
}