nodejs
diff --git a/Collapse file
‎lib/internal/streams/pipeline.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/pipeline.js
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎lib/internal/streams/pipeline.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/pipeline.js
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-stream-pipeline.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-pipeline.js
+21Lines changed: 21 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-pipeline.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-pipeline.js
+21Lines changed: 21 additions & 0 deletions
@@ -227,7 +227,7 @@ function pipelineImpl(streams, callback, opts) {
   }
 
   function finishImpl(err, final) {
-    if (err && (!error || error.code === 'ERR_STREAM_PREMATURE_CLOSE')) {
+    if (err && (!error || error.code === 'ERR_STREAM_PREMATURE_CLOSE' || error.name === 'AbortError')) {
       error = err;
     }
 
 
@@ -1749,3 +1749,24 @@ tmpdir.refresh();
     assert.deepStrictEqual(err, new Error('booom'));
   }));
 }
+
+{
+  // Errors thrown in Readable.map inside pipeline should not be
+  // swallowed by AbortError when the source is an infinite stream.
+  pipeline(
+    new Readable({ read() { this.push('data'); } }),
+    new Transform({
+      readableObjectMode: true,
+      transform(chunk, encoding, callback) {
+        this.push({});
+        callback();
+      },
+    }),
+    (readable) => readable.map(async () => {
+      throw new Error('Boom!');
+    }),
+    common.mustCall((err) => {
+      assert.strictEqual(err.message, 'Boom!');
+    }),
+  );
+}
Original file line number	Diff line number	Diff line change
`@@ -227,7 +227,7 @@ function pipelineImpl(streams, callback, opts) {`
`227`	`227`	`}`
`228`	`228`
`229`	`229`	`function finishImpl(err, final) {`
`230`		`- if (err && (!error \|\| error.code === 'ERR_STREAM_PREMATURE_CLOSE')) {`
	`230`	`+ if (err && (!error \|\| error.code === 'ERR_STREAM_PREMATURE_CLOSE' \|\| error.name === 'AbortError')) {`
`231`	`231`	`error = err;`
`232`	`232`	`}`
`233`	`233`