async function benchPipeThrough(iterations, chunks) {
  const encoder = new TextEncoder();
  const data = encoder.encode("x");
  const start = performance.now();
  for (let i = 0; i < iterations; i++) {
    const stream = new ReadableStream({
      start(controller) {
        for (let j = 0; j < chunks; j++) controller.enqueue(data);
        controller.close();
      },
    });
    const reader = stream.pipeThrough(new TextDecoderStream()).getReader();
    while (true) {
      const { done } = await reader.read();
      if (done) break;
    }
  }
  const elapsed = performance.now() - start;
  const opsPerSec = ((iterations * chunks) / elapsed * 1000).toFixed(0);
  console.log(`pipeThrough ${chunks} chunks: ${elapsed.toFixed(1)} ms (${opsPerSec} chunks/s)`);
}

async function benchPipeTo(iterations, chunks) {
  const start = performance.now();
  for (let i = 0; i < iterations; i++) {
    const readable = new ReadableStream({
      start(controller) {
        for (let j = 0; j < chunks; j++) controller.enqueue(j);
        controller.close();
      },
    });
    const writable = new WritableStream({ write() {} });
    await readable.pipeTo(writable);
  }
  const elapsed = performance.now() - start;
  const opsPerSec = ((iterations * chunks) / elapsed * 1000).toFixed(0);
  console.log(`pipeTo ${chunks} chunks: ${elapsed.toFixed(1)} ms (${opsPerSec} chunks/s)`);
}

async function benchTransformStream(iterations, chunks) {
  const start = performance.now();
  for (let i = 0; i < iterations; i++) {
    const transform = new TransformStream({
      transform(chunk, controller) { controller.enqueue(chunk); },
    });
    const writer = transform.writable.getWriter();
    const reader = transform.readable.getReader();
    const writePromise = (async () => {
      for (let j = 0; j < chunks; j++) await writer.write(j);
      await writer.close();
    })();
    while (true) {
      const { done } = await reader.read();
      if (done) break;
    }
    await writePromise;
  }
  const elapsed = performance.now() - start;
  const opsPerSec = ((iterations * chunks) / elapsed * 1000).toFixed(0);
  console.log(`TransformStream ${chunks} chunks: ${elapsed.toFixed(1)} ms (${opsPerSec} chunks/s)`);
}

// Warmup
await benchPipeThrough(3, 100);
await benchPipeTo(3, 100);
await benchTransformStream(3, 100);

console.log("\n--- Benchmark ---");
await benchPipeThrough(100, 1000);
await benchPipeTo(500, 1000);
await benchTransformStream(500, 1000);