René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"stream/iter consumers do not reject on abort while async iterator is pending","articleBody":"### Version\n\nmain\n\n### Platform\n\n```text\nmacOS 26.5.0\n```\n\n### Subsystem\n\nstream\n\n### What steps will reproduce the bug?\n\n```js\nimport {\n  array,\n  arrayBuffer,\n  bytes,\n  text,\n} from 'node:stream/iter';\nimport { setTimeout } from 'node:timers/promises';\n\nasync function* never() {\n  await new Promise(() =\u003e {});\n}\n\nasync function check(name, fn) {\n  const ac = new AbortController();\n\n  setTimeout(10).then(() =\u003e ac.abort(new Error('boom')));\n\n  const result = await Promise.race([\n    fn(never(), { signal: ac.signal })\n      .then(() =\u003e `${name} resolved`)\n      .catch((err) =\u003e `${name} rejected: ${err.message}`),\n    setTimeout(80, `${name} timeout`),\n  ]);\n\n  console.log(result);\n}\n\nawait check('bytes', bytes);\nawait check('text', text);\nawait check('arrayBuffer', arrayBuffer);\nawait check('array', array);\n```\n\n### How often does it reproduce? Is there a required condition?\n\nAlways\n\n### What is the expected behavior? Why is that the expected behavior?\n\n```console\nbytes rejected: boom\ntext rejected: boom\narrayBuffer rejected: boom\narray rejected: boom\n```\n\n### What do you see instead?\n\n```console\nbytes timeout\ntext timeout\narrayBuffer timeout\narray timeout\n```\n\nAll four consumers accept `{ signal }`, but aborting the signal does not settle the operation while the source’s async iterator is stuck in a pending `next()`. They should reject promptly with the abort reason instead of waiting for another batch to arrive.\n\n### Additional information\n\n_No response_","author":{"url":"https://github.com/trivikr","@type":"Person","name":"trivikr"},"datePublished":"2026-06-22T14:47:54.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/64065/node/issues/64065"}