fixup: less breaking version

Author: ronag

lib/_stream_writable.js

@@ -650,7 +650,7 @@ function callFinal(stream, state) {
     } else {
       state.prefinished = true;
       stream.emit('prefinish');
-      finishMaybe(stream, state);
+      finishMaybe(stream, state, false);
     }
   });
 }
@@ -667,30 +667,38 @@ function prefinish(stream, state) {
   }
 }
 
-function finishMaybe(stream, state) {
+function finishMaybe(stream, state, sync) {
   const need = needFinish(state);
   if (need) {
     prefinish(stream, state);
     if (state.pendingcb === 0) {
-      state.finished = true;
-      stream.emit('finish');
-
-      if (state.autoDestroy) {
-        // In case of duplex streams we need a way to detect
-        // if the readable side is ready for autoDestroy as well
-        const rState = stream._readableState;
-        if (!rState || (rState.autoDestroy && rState.endEmitted)) {
-          stream.destroy();
-        }
+      if (sync) {
+        process.nextTick(finishWritable, stream, state);
+      } else {
+        finishWritable(stream, state);
       }
     }
   }
   return need;
 }
 
+function finishWritable(stream, state) {
+  state.finished = true;
+  stream.emit('finish');
+
+  if (state.autoDestroy) {
+    // In case of duplex streams we need a way to detect
+    // if the readable side is ready for autoDestroy as well
+    const rState = stream._readableState;
+    if (!rState || (rState.autoDestroy && rState.endEmitted)) {
+      stream.destroy();
+    }
+  }
+}
+
 function endWritable(stream, state, cb) {
   state.ending = true;
-  process.nextTick(finishMaybe, stream, state);
+  finishMaybe(stream, state, true);
   if (cb) {
     if (state.finished)
       process.nextTick(cb);