fixup: test

nodejs · Mar 3, 2020 · efd93fb · efd93fb
1 parent 9d1ee32
commit efd93fb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js
@@ -72,14 +72,14 @@ function eos(stream, opts, callback) {
     (wState && wState.finished);
   const onfinish = () => {
     writableFinished = true;
-    if (!readable) callback.call(stream);
+    if (!readable || readableEnded) callback.call(stream);
   };
 
   let readableEnded = stream.readableEnded ||
     (rState && rState.endEmitted);
   const onend = () => {
     readableEnded = true;
-    if (!writable) callback.call(stream);
+    if (!writable || writableFinished) callback.call(stream);
   };
 
   const onerror = (err) => {