René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Errors thrown in `stream.pipeline` streams can get swallowed by `AbortError`","articleBody":"### Version\n\nv25.7.0\n\n### Platform\n\n```text\nDarwin MacBook.local 24.6.0 Darwin Kernel Version 24.6.0: Mon Jan 19 22:00:10 PST 2026; root:xnu-11417.140.69.708.3~1/RELEASE_X86_64 x86_64\n```\n\n### Subsystem\n\n_No response_\n\n### What steps will reproduce the bug?\n\n```js\nimport fs from 'node:fs';\nimport { Readable, Transform } from 'node:stream';\nimport { pipeline } from 'node:stream/promises';\n\nexport async function main({ sourceStream, transformPushCount }) {\n  await pipeline(\n    sourceStream,\n\n    new Transform({\n      readableObjectMode: true,\n      transform(chunk, encoding, callback) {\n        for (let i = 0; i \u003c transformPushCount; i++) {\n          this.push({});\n        }\n        callback();\n      },\n    }),\n\n    (readable) =\u003e\n      readable.map(async (obj) =\u003e {\n        throw Error('Boom!');\n      })\n  );\n}\n\nif (import.meta.main) {\n  try {\n    await main({\n      sourceStream: fs.createReadStream('/dev/urandom'),\n      transformPushCount: 1,\n    });\n  } catch (e) {\n    console.log(`sourceStream: file, transformPushCount: once, error: ${e}`);\n  }\n  try {\n    await main({\n      sourceStream: fs.createReadStream('/dev/urandom'),\n      transformPushCount: 2,\n    });\n  } catch (e) {\n    console.log(`sourceStream: file, transformPushCount: twice, error: ${e}`);\n  }\n\n  try {\n    await main({\n      sourceStream: Readable.from(['foo']),\n      transformPushCount: 1,\n    });\n  } catch (e) {\n    console.log(\n      `sourceStream: readable from iterable, transformPushCount: once, error: ${e}`\n    );\n  }\n  try {\n    await main({\n      sourceStream: Readable.from(['foo']),\n      transformPushCount: 2,\n    });\n  } catch (e) {\n    console.log(\n      `sourceStream: readable from iterable, transformPushCount: twice, error: ${e}`\n    );\n  }\n\n  try {\n    await main({\n      sourceStream: new Readable({\n        read(size) {\n          this.push('foo');\n        },\n      }),\n      transformPushCount: 1,\n    });\n  } catch (e) {\n    console.log(\n      `sourceStream: readable implementation, transformPushCount: once, error: ${e}`\n    );\n  }\n  try {\n    await main({\n      sourceStream: new Readable({\n        read(size) {\n          this.push('foo');\n        },\n      }),\n      transformPushCount: 2,\n    });\n  } catch (e) {\n    console.log(\n      `sourceStream: readable implementation, transformPushCount: twice, error: ${e}`\n    );\n  }\n}\n```\n\n### How often does it reproduce? Is there a required condition?\n\nIt reproduces each time.\n\n### What is the expected behavior? Why is that the expected behavior?\n\nI would expect the pipeline call to be rejected with `Error: Boom!` in all cases shown in the example code.\n\n### What do you see instead?\n\n```plain\nsourceStream: file, transformPushCount: once, error: Error: Boom!\nsourceStream: file, transformPushCount: twice, error: AbortError: The operation was aborted\nsourceStream: readable from iterable, transformPushCount: once, error: Error: Boom!\nsourceStream: readable from iterable, transformPushCount: twice, error: Error: Boom!\nsourceStream: readable implementation, transformPushCount: once, error: AbortError: The operation was aborted\nsourceStream: readable implementation, transformPushCount: twice, error: AbortError: The operation was aborted\n```\n\n### Additional information\n\nThe example came out of a larger code that reads a CSV file, parses it to objects using the csv-parse library, and then uses `Radable.map` to call a third-party API concurrently for every parsed record. The API credentials I've been using expired, causing the pipeline to reject with `AbortError`, though I'd expect it to reject with 401 Unauthorized.","author":{"url":"https://github.com/hs-kgoriunov","@type":"Person","name":"hs-kgoriunov"},"datePublished":"2026-03-03T14:52:23.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/62089/node/issues/62089"}