nodejs
diff --git a/‎lib/internal/streams/utils.js‎
Lines changed: 4 additions & 2 deletions b/‎lib/internal/streams/utils.js‎
Lines changed: 4 additions & 2 deletions
diff --git a/‎test/parallel/test-stream-pipeline.js‎
Lines changed: 16 additions & 0 deletions b/‎test/parallel/test-stream-pipeline.js‎
Lines changed: 16 additions & 0 deletions
@@ -6,11 +6,13 @@ const {
 } = primordials;
 
 function isReadable(obj) {
-  return !!(obj && typeof obj.pipe === 'function');
+  return !!(obj && typeof obj.pipe === 'function' &&
+            typeof obj.on === 'function');
 }
 
 function isWritable(obj) {
-  return !!(obj && typeof obj.write === 'function');
+  return !!(obj && typeof obj.write === 'function' &&
+            typeof obj.on === 'function');
 }
 
 function isStream(obj) {
 
@@ -1247,3 +1247,19 @@ const net = require('net');
     () => common.mustNotCall(),
   );
 }
+
+{
+  const content = 'abc';
+  pipeline(Buffer.from(content), PassThrough({ objectMode: true }),
+           common.mustSucceed(() => {}));
+
+  let res = '';
+  pipeline(Buffer.from(content), async function*(previous) {
+    for await (const val of previous) {
+      res += String.fromCharCode(val);
+      yield val;
+    }
+  }, common.mustSucceed(() => {
+    assert.strictEqual(res, content);
+  }));
+}
Original file line number	Diff line number	Diff line change
@@ -6,11 +6,13 @@ const {
6	6	} = primordials;
7	7
8	8	function isReadable(obj) {
9		- return !!(obj && typeof obj.pipe === 'function');
	9	+ return !!(obj && typeof obj.pipe === 'function' &&
	10	+ typeof obj.on === 'function');
10	11	}
11	12
12	13	function isWritable(obj) {
13		- return !!(obj && typeof obj.write === 'function');
	14	+ return !!(obj && typeof obj.write === 'function' &&
	15	+ typeof obj.on === 'function');
14	16	}
15	17
16	18	function isStream(obj) {