stream: eos make const state const

writable & readable is based on type and is not actual
state, treat them as such.

PR-URL: #32031
Reviewed-By: Matteo Collina <[email protected]>
Reviewed-By: Luigi Pinca <[email protected]>

Author: ronag

lib/internal/streams/end-of-stream.js

@@ -56,9 +56,9 @@ function eos(stream, opts, callback) {
 
   callback = once(callback);
 
-  let readable = opts.readable ||
+  const readable = opts.readable ||
     (opts.readable !== false && isReadable(stream));
-  let writable = opts.writable ||
+  const writable = opts.writable ||
     (opts.writable !== false && isWritable(stream));
 
   const wState = stream._writableState;
@@ -71,35 +71,31 @@ function eos(stream, opts, callback) {
   let writableFinished = stream.writableFinished ||
     (wState && wState.finished);
   const onfinish = () => {
-    writable = false;
     writableFinished = true;
-    if (!readable) callback.call(stream);
+    if (!readable || readableEnded) callback.call(stream);
   };
 
   let readableEnded = stream.readableEnded ||
     (rState && rState.endEmitted);
   const onend = () => {
-    readable = false;
     readableEnded = true;
-    if (!writable) callback.call(stream);
+    if (!writable || writableFinished) callback.call(stream);
   };
 
   const onerror = (err) => {
     callback.call(stream, err);
   };
 
   const onclose = () => {
-    let err;
     if (readable && !readableEnded) {
       if (!isReadableEnded(stream))
-        err = new ERR_STREAM_PREMATURE_CLOSE();
-      return callback.call(stream, err);
+        return callback.call(stream, new ERR_STREAM_PREMATURE_CLOSE());
     }
     if (writable && !writableFinished) {
       if (!isWritableFinished(stream))
-        err = new ERR_STREAM_PREMATURE_CLOSE();
-      return callback.call(stream, err);
+        return callback.call(stream, new ERR_STREAM_PREMATURE_CLOSE());
     }
+    callback.call(stream);
   };
 
   const onrequest = () => {

test/parallel/test-stream-finished.js

@@ -181,7 +181,7 @@ const { promisify } = require('util');
   const streamLike = new EE();
   streamLike.readableEnded = true;
   streamLike.readable = true;
-  finished(streamLike, common.mustCall);
+  finished(streamLike, common.mustCall());
   streamLike.emit('close');
 }