Function slowSource

test/parallel/test-stream-iter-broadcast-from.js:100–107

()

  // Create a slow async source that blocks between yields
  let sourceFinished = false;
  async function* slowSource() {
    const enc = new TextEncoder();
    yield [enc.encode('chunk1')];
    // Simulate a long delay - the cancel should unblock this
    await new Promise((resolve) => setTimeout(resolve, 10000));
    yield [enc.encode('chunk2')];
    sourceFinished = true;
  }

  const { broadcast: bc } = Broadcast.from(slowSource());
  const consumer = bc.push();