stream/iter consumers do not reject on abort while async iterator is pending #64065

import {
  array,
  arrayBuffer,
  bytes,
  text,
} from 'node:stream/iter';
import { setTimeout } from 'node:timers/promises';

async function* never() {
  await new Promise(() => {});
}

async function check(name, fn) {
  const ac = new AbortController();

  setTimeout(10).then(() => ac.abort(new Error('boom')));

  const result = await Promise.race([
    fn(never(), { signal: ac.signal })
      .then(() => `${name} resolved`)
      .catch((err) => `${name} rejected: ${err.message}`),
    setTimeout(80, `${name} timeout`),
  ]);

  console.log(result);
}

await check('bytes', bytes);
await check('text', text);
await check('arrayBuffer', arrayBuffer);
await check('array', array);