fixuP

nodejs · Nov 18, 2021 · 15adae8 · 15adae8
1 parent e256132
commit 15adae8
Showing 1 changed file with 8 additions and 10 deletions.
diff --git a/lib/internal/streams/writable.js b/lib/internal/streams/writable.js
@@ -734,17 +734,10 @@ function finishMaybe(stream, state, sync) {
   if (needFinish(state)) {
     prefinish(stream, state);
     if (state.pendingcb === 0) {
+      state.pendingcb++;
       if (sync) {
-        state.pendingcb++;
-        process.nextTick((stream, state) => {
-          if (needFinish(state)) {
-            finish(stream, state);
-          } else {
-            state.pendingcb--;
-          }
-        }, stream, state);
-      } else if (needFinish(state)) {
-        state.pendingcb++;
+        process.nextTick(finish);
+      } else {
         finish(stream, state);
       }
     }
@@ -753,6 +746,11 @@ function finishMaybe(stream, state, sync) {
 
 function finish(stream, state) {
   state.pendingcb--;
+
+  if (!needFinish(state)) {
+    return;
+  }
+
   state.finished = true;
 
   const onfinishCallbacks = state[kOnFinished].splice(0);