Function testAbortSignal

test/parallel/test-stream-iter-broadcast-from.js:66–79

()

// =============================================================================

async function testAbortSignal() {
  const ac = new AbortController();
  const { broadcast: bc } = broadcast({ signal: ac.signal });
  const consumer = bc.push();

  ac.abort();

  await assert.rejects(async () => {
    // eslint-disable-next-line no-unused-vars
    for await (const _ of consumer) {
      assert.fail('Should not reach here');
    }
  }, { name: 'AbortError' });
}

async function testAlreadyAbortedSignal() {
  const { broadcast: bc } = broadcast({ signal: AbortSignal.abort() });