René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"stream/iter: per-consumer AbortSignal is ignored by broadcast.push() and share.pull() fast path","articleBody":"### Version\n\n26.1.0\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 { setTimeout as delay } from \"node:timers/promises\";\nimport { broadcast, share } from \"node:stream/iter\";\n\nasync function check(label, next) {\n  console.log(\n    await Promise.race([\n      next.then(\n        (value) =\u003e `${label}: settled ${JSON.stringify(value)}`,\n        (error) =\u003e `${label}: rejected ${error?.name ?? error}`,\n      ),\n      delay(50, `${label}: still pending`),\n    ]),\n  );\n}\n\n{\n  const ac = new AbortController();\n  const { broadcast: bc } = broadcast();\n  const it = bc.push({ signal: ac.signal })[Symbol.asyncIterator]();\n\n  const next = it.next();\n  ac.abort(new Error(\"abort\"));\n\n  await check(\"broadcast.push({ signal }).next()\", next);\n}\n\n{\n  const ac = new AbortController();\n  const shared = share(\n    (async function* never() {\n      await new Promise(() =\u003e {});\n    })(),\n  );\n  const it = shared.pull({ signal: ac.signal })[Symbol.asyncIterator]();\n\n  const next = it.next();\n  ac.abort(new Error(\"abort\"));\n\n  await check(\"share.pull({ signal }).next()\", next);\n}\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\nbroadcast.push({ signal }).next(): rejected Error\nshare.pull({ signal }).next(): rejected Error\n```\n\n### What do you see instead?\n\n```console\nbroadcast.push({ signal }).next(): still pending\nshare.pull({ signal }).next(): still pending\n```\n\n### Additional information\n\n_No response_","author":{"url":"https://github.com/trivikr","@type":"Person","name":"trivikr"},"datePublished":"2026-05-14T04:23:01.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/63302/node/issues/63302"}