test: test streambase has already has a consumer

test: test streambase has already has a consumer PR-URL: #48059 Reviewed-By: Antoine du Hamel <[email protected]> Reviewed-By: James M Snell <[email protected]>
nodejs · Nov 23, 2023 · 377dede · 377dede
1 parent 0d3aa72
commit 377dede
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 0 deletions.
diff --git a/test/parallel/test-whatwg-webstreams-adapters-streambase.js b/test/parallel/test-whatwg-webstreams-adapters-streambase.js
@@ -65,3 +65,12 @@ const {
   const readable = newReadableStreamFromStreamBase(stream);
   readable.cancel().then(common.mustCall());
 }
+
+{
+  const stream = new JSStream();
+  stream.onread = common.mustCall();
+  assert.throws(() => newReadableStreamFromStreamBase(stream), {
+    code: 'ERR_INVALID_STATE'
+  });
+  stream.emitEOF();
+}
diff --git a/test/parallel/test-whatwg-webstreams-adapters-to-readablewritablepair.js b/test/parallel/test-whatwg-webstreams-adapters-to-readablewritablepair.js
@@ -248,3 +248,9 @@ const {
   reader.closed.then(common.mustCall());
   writer.close().then(common.mustCall());
 }
+
+{
+  assert.throws(() => newReadableWritablePairFromDuplex(null), {
+    code: 'ERR_INVALID_ARG_TYPE'
+  });
+}
diff --git a/test/parallel/test-whatwg-webstreams-adapters-to-streamduplex.js b/test/parallel/test-whatwg-webstreams-adapters-to-streamduplex.js
@@ -164,3 +164,21 @@ const {
 
   duplex.end();
 }
+
+{
+  const transform = { readable: {}, writable: {} };
+  assert.throws(() => newStreamDuplexFromReadableWritablePair(transform), {
+    code: 'ERR_INVALID_ARG_TYPE'
+  });
+}
+
+{
+  const transform = {
+    readable: new ReadableStream(),
+    writable: null
+  };
+
+  assert.throws(() => newStreamDuplexFromReadableWritablePair(transform), {
+    code: 'ERR_INVALID_ARG_TYPE',
+  });
+}