stream: reject TransformStream in addAbortSignal

Author: ikeyan

lib/internal/streams/add-abort-signal.js

@@ -13,7 +13,8 @@ const {
 
 const {
   isNodeStream,
-  isWebStream,
+  isReadableStream,
+  isWritableStream,
   kControllerAbortFunction,
 } = require('internal/streams/utils');
 
@@ -32,7 +33,9 @@ const validateAbortSignal = (signal, name) => {
 
 module.exports.addAbortSignal = function addAbortSignal(signal, stream) {
   validateAbortSignal(signal, 'signal');
-  if (!isNodeStream(stream) && !isWebStream(stream)) {
+  if (!isNodeStream(stream) &&
+      !isReadableStream(stream) &&
+      !isWritableStream(stream)) {
     throw new ERR_INVALID_ARG_TYPE('stream', ['ReadableStream', 'WritableStream', 'Stream'], stream);
   }
   return module.exports.addAbortSignalNoValidate(signal, stream);

test/parallel/test-stream-add-abort-signal.js

@@ -4,6 +4,7 @@
 require('../common');
 const assert = require('assert');
 const { addAbortSignal, Readable } = require('stream');
+const { TransformStream } = require('stream/web');
 const {
   addAbortSignalNoValidate,
 } = require('internal/streams/add-abort-signal');
@@ -17,6 +18,10 @@ const {
   assert.throws(() => {
     addAbortSignal(ac.signal, 'INVALID_STREAM');
   }, /ERR_INVALID_ARG_TYPE/);
+
+  assert.throws(() => {
+    addAbortSignal(ac.signal, new TransformStream());
+  }, /ERR_INVALID_ARG_TYPE/);
 }
 
 {