nodejs
diff --git a/Collapse file
‎lib/internal/streams/end-of-stream.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/end-of-stream.js
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎lib/internal/streams/end-of-stream.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/end-of-stream.js
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎lib/internal/streams/utils.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/utils.js
+5-1Lines changed: 5 additions & 1 deletion b/Collapse file
‎lib/internal/streams/utils.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/utils.js
+5-1Lines changed: 5 additions & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-stream-finished.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-finished.js
+17Lines changed: 17 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-finished.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-finished.js
+17Lines changed: 17 additions & 0 deletions
@@ -116,7 +116,7 @@ function eos(stream, options, callback) {
       return callback.call(stream, errored);
     }
 
-    if (readable && !readableFinished) {
+    if (readable && !readableFinished && isReadableNodeStream(stream, true)) {
       if (!isReadableFinished(stream, false))
         return callback.call(stream,
                              new ERR_STREAM_PREMATURE_CLOSE());
 
@@ -9,11 +9,15 @@ const {
 const kDestroyed = Symbol('kDestroyed');
 const kIsDisturbed = Symbol('kIsDisturbed');
 
-function isReadableNodeStream(obj) {
+function isReadableNodeStream(obj, strict = false) {
   return !!(
     obj &&
     typeof obj.pipe === 'function' &&
     typeof obj.on === 'function' &&
+    (
+      !strict ||
+      (typeof obj.pause === 'function' && typeof obj.resume === 'function')
+    ) &&
     (!obj._writableState || obj._readableState?.readable !== false) && // Duplex
     (!obj._writableState || obj._readableState) // Writable has .pipe.
   );
 
@@ -639,3 +639,20 @@ testClosed((opts) => new Writable({ write() {}, ...opts }));
   const s = new Stream();
   finished(s, common.mustNotCall());
 }
+
+{
+  const server = http.createServer(common.mustCall(function(req, res) {
+    fs.createReadStream(__filename).pipe(res);
+    finished(res, common.mustCall(function(err) {
+      assert.strictEqual(err, undefined);
+    }));
+  })).listen(0, function() {
+    http.request(
+      { method: 'GET', port: this.address().port },
+      common.mustCall(function(res) {
+        res.resume();
+        server.close();
+      })
+    ).end();
+  });
+}
Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ function eos(stream, options, callback) {`
`116`	`116`	`return callback.call(stream, errored);`
`117`	`117`	`}`
`118`	`118`
`119`		`- if (readable && !readableFinished) {`
	`119`	`+ if (readable && !readableFinished && isReadableNodeStream(stream, true)) {`
`120`	`120`	`if (!isReadableFinished(stream, false))`
`121`	`121`	`return callback.call(stream,`
`122`	`122`	`new ERR_STREAM_PREMATURE_CLOSE());`