nodejs
diff --git a/Collapse file
‎lib/internal/streams/duplexify.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/duplexify.js
-2Lines changed: 0 additions & 2 deletions b/Collapse file
‎lib/internal/streams/duplexify.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/duplexify.js
-2Lines changed: 0 additions & 2 deletions
diff --git a/Collapse file
‎test/parallel/test-stream-duplex-from.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-duplex-from.js
+22-1Lines changed: 22 additions & 1 deletion b/Collapse file
‎test/parallel/test-stream-duplex-from.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-duplex-from.js
+22-1Lines changed: 22 additions & 1 deletion
@@ -262,8 +262,6 @@ function _duplexify(pair) {
       cb(err);
     } else if (err) {
       d.destroy(err);
-    } else if (!readable && !writable) {
-      d.destroy();
     }
   }
 
 
@@ -2,7 +2,7 @@
 
 const common = require('../common');
 const assert = require('assert');
-const { Duplex, Readable, Writable, pipeline } = require('stream');
+const { Duplex, Readable, Writable, pipeline, PassThrough } = require('stream');
 const { Blob } = require('buffer');
 
 {
@@ -278,3 +278,24 @@ const { Blob } = require('buffer');
 
   duplex.write('test');
 }
+
+{
+  const through = new PassThrough({ objectMode: true });
+
+  let res = '';
+  const d = Readable.from(['foo', 'bar'], { objectMode: true })
+    .pipe(Duplex.from({
+      writable: through,
+      readable: through
+    }));
+
+  d.on('data', (data) => {
+    d.pause();
+    setImmediate(() => {
+      d.resume();
+    });
+    res += data;
+  }).on('end', common.mustCall(() => {
+    assert.strictEqual(res, 'foobar');
+  })).on('close', common.mustCall());
+}
Original file line number	Diff line number	Diff line change
`@@ -262,8 +262,6 @@ function _duplexify(pair) {`
`262`	`262`	`cb(err);`
`263`	`263`	`} else if (err) {`
`264`	`264`	`d.destroy(err);`
`265`		`- } else if (!readable && !writable) {`
`266`		`- d.destroy();`
`267`	`265`	`}`
`268`	`266`	`}`
`269`	`267`