nodejs
diff --git a/‎lib/internal/streams/iter/push.js‎
Lines changed: 2 additions & 4 deletions b/‎lib/internal/streams/iter/push.js‎
Lines changed: 2 additions & 4 deletions
diff --git a/‎test/parallel/test-stream-iter-push-basic.js‎
Lines changed: 11 additions & 0 deletions b/‎test/parallel/test-stream-iter-push-basic.js‎
Lines changed: 11 additions & 0 deletions
@@ -25,7 +25,7 @@ const {
     ERR_INVALID_STATE,
   },
 } = require('internal/errors');
-const { isError, lazyDOMException } = require('internal/util');
+const { lazyDOMException } = require('internal/util');
 const {
   validateAbortSignal,
   validateInteger,
@@ -135,9 +135,7 @@ class PushQueue {
 
     if (this.#signal) {
       this.#abortHandler = () => {
-        this.fail(isError(this.#signal.reason) ?
-          this.#signal.reason :
-          lazyDOMException('Aborted', 'AbortError'));
+        this.fail(this.#signal.reason);
       };
       onSignalAbort(this.#signal, this.#abortHandler);
     }
 
@@ -107,6 +107,16 @@ async function testAbortSignal() {
   );
 }
 
+async function testAbortSignalReason() {
+  const reason = 'test reason';
+  const ac = new AbortController();
+  const { writer } = push({ signal: ac.signal });
+
+  ac.abort(reason);
+
+  await assert.rejects(writer.write('data'), (err) => err === reason);
+}
+
 async function testPreAbortedSignal() {
   const { readable } = push({ signal: AbortSignal.abort() });
   await assert.rejects(async () => {
@@ -172,6 +182,7 @@ Promise.all([
   testWriterFail(),
   testConsumerBreak(),
   testAbortSignal(),
+  testAbortSignalReason(),
   testPreAbortedSignal(),
   testConsumerBreakWriteSyncReturnsFalse(),
   testPushWithTransforms(),