nodejs
diff --git a/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
-5Lines changed: 0 additions & 5 deletions b/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
-5Lines changed: 0 additions & 5 deletions
diff --git a/Collapse file
‎test/parallel/test-readable-from-web-enqueue-then-close.js‎
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions b/Collapse file
‎test/parallel/test-readable-from-web-enqueue-then-close.js‎
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions
@@ -32,7 +32,6 @@ const {
 const {
   isDestroyed,
   isReadable,
-  isReadableEnded,
   isWritable,
   isWritableEnded,
 } = require('internal/streams/utils');
@@ -528,8 +527,6 @@ function newStreamReadableFromReadableStream(readableStream, options = kEmptyObj
     reader.closed,
     () => {
       closed = true;
-      if (!isReadableEnded(readable))
-        readable.push(null);
     },
     (error) => {
       closed = true;
@@ -794,8 +791,6 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
     reader.closed,
     () => {
       readableClosed = true;
-      if (!isReadableEnded(duplex))
-        duplex.push(null);
     },
     (error) => {
       writableClosed = true;
 
@@ -0,0 +1,26 @@
+'use strict';
+const { mustCall } = require('../common');
+const { Readable, Duplex } = require('stream');
+const { strictEqual } = require('assert');
+
+function start(controller) {
+  controller.enqueue(new Uint8Array(1));
+  controller.close();
+}
+
+Readable.fromWeb(new ReadableStream({ start }))
+.on('data', mustCall((d) => {
+  strictEqual(d.length, 1);
+}))
+.on('end', mustCall())
+.resume();
+
+Duplex.fromWeb({
+  readable: new ReadableStream({ start }),
+  writable: new WritableStream({ write(chunk) {} })
+})
+.on('data', mustCall((d) => {
+  strictEqual(d.length, 1);
+}))
+.on('end', mustCall())
+.resume();