nodejs
diff --git a/Collapse file
‎lib/internal/streams/readable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/readable.js
+3-2Lines changed: 3 additions & 2 deletions b/Collapse file
‎lib/internal/streams/readable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/readable.js
+3-2Lines changed: 3 additions & 2 deletions
diff --git a/Collapse file
‎lib/internal/streams/writable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/writable.js
+3-2Lines changed: 3 additions & 2 deletions b/Collapse file
‎lib/internal/streams/writable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/writable.js
+3-2Lines changed: 3 additions & 2 deletions
@@ -43,7 +43,7 @@ const { Stream, prependListener } = require('internal/streams/legacy');
 const { Buffer } = require('buffer');
 
 const {
-  addAbortSignalNoValidate,
+  addAbortSignal,
 } = require('internal/streams/add-abort-signal');
 const eos = require('internal/streams/end-of-stream');
 
@@ -199,8 +199,9 @@ function Readable(options) {
 
     if (typeof options.construct === 'function')
       this._construct = options.construct;
+
     if (options.signal && !isDuplex)
-      addAbortSignalNoValidate(options.signal, this);
+      addAbortSignal(options.signal, this);
   }
 
   Stream.call(this, options);
 
@@ -46,7 +46,7 @@ const { Buffer } = require('buffer');
 const destroyImpl = require('internal/streams/destroy');
 
 const {
-  addAbortSignalNoValidate,
+  addAbortSignal,
 } = require('internal/streams/add-abort-signal');
 
 const {
@@ -249,8 +249,9 @@ function Writable(options) {
 
     if (typeof options.construct === 'function')
       this._construct = options.construct;
+
     if (options.signal)
-      addAbortSignalNoValidate(options.signal, this);
+      addAbortSignal(options.signal, this);
   }
 
   Stream.call(this, options);