Function testRingbufferGrow

test/parallel/test-stream-iter-broadcast-coverage.js:76–97

()

// Ringbuffer grow — push > 16 items without consumer draining
async function testRingbufferGrow() {
  const { writer, broadcast: bc } = broadcast({ highWaterMark: 32 });
  const consumer = bc.push();

  // Push 20 items (exceeds default ringbuffer capacity of 16)
  for (let i = 0; i < 20; i++) {
    writer.writeSync(new Uint8Array([i]));
  }
  writer.endSync();

  // Read all items back and verify order
  const items = [];
  for await (const batch of consumer) {
    for (const chunk of batch) {
      items.push(chunk[0]);
    }
  }
  assert.strictEqual(items.length, 20);
  for (let i = 0; i < 20; i++) {
    assert.strictEqual(items[i], i);
  }
}

// Multiple consumers at the minimum cursor should trim only after the last
// one advances or detaches.