René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"stream/iter pipeTo() does not observe abort while waiting for the next source chunk","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 { pipeTo } from \"node:stream/iter\";\nimport { setTimeout } from \"node:timers/promises\";\n\nasync function* neverYieldingSource() {\n  await new Promise(() =\u003e {});\n}\n\nconst writer = {\n  write() {},\n};\n\nconst ac = new AbortController();\n\nsetTimeout(100).then(() =\u003e {\n  ac.abort(new Error(\"abort reason\"));\n});\n\nconst result = await Promise.race([\n  pipeTo(neverYieldingSource(), writer, { signal: ac.signal }).then(\n    () =\u003e \"pipeTo resolved\",\n    (error) =\u003e `pipeTo rejected: ${error.name}: ${error.message}`,\n  ),\n  setTimeout(1000, \"timed out\"),\n]);\n\nconsole.log(result);\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\npipeTo rejected: Error: abort reason\n```\n\n`pipeTo()` should reject promptly when `options.signal` aborts, even while waiting for the next source chunk in the no-transform path.\n\n\n### What do you see instead?\n\n```console\ntimed out\n```\n\n`pipeTo()` checks `signal.throwIfAborted()` only after `for await` produces a batch, so a pending source read that never settles prevents abort from being observed.\n\n### Additional information\n\n_No response_","author":{"url":"https://github.com/trivikr","@type":"Person","name":"trivikr"},"datePublished":"2026-06-20T01:10:10.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/64014/node/issues/64014"}