nodejs
diff --git a/Collapse file
‎lib/_stream_writable.js‎
Copy file name to clipboardExpand all lines: lib/_stream_writable.js
+4-12Lines changed: 4 additions & 12 deletions b/Collapse file
‎lib/_stream_writable.js‎
Copy file name to clipboardExpand all lines: lib/_stream_writable.js
+4-12Lines changed: 4 additions & 12 deletions
@@ -478,21 +478,13 @@ function onwrite(stream, er) {
 }
 
 function afterWrite(stream, state, finished, cb) {
-  if (!finished)
-    onwriteDrain(stream, state);
-  state.pendingcb--;
-  cb();
-  finishMaybe(stream, state);
-}
-
-// Must force callback to be called on nextTick, so that we don't
-// emit 'drain' before the write() consumer gets the 'false' return
-// value, and has a chance to attach a 'drain' listener.
-function onwriteDrain(stream, state) {
-  if (state.length === 0 && state.needDrain) {
+  if (!finished && state.length === 0 && state.needDrain) {
     state.needDrain = false;
     stream.emit('drain');
   }
+  state.pendingcb--;
+  cb();
+  finishMaybe(stream, state);
 }
 
 // If there's something in the buffer waiting, then process it