fixup

nodejs · Sep 5, 2020 · ab7b73d · ab7b73d
1 parent 6734876
commit ab7b73d
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/lib/_stream_writable.js b/lib/_stream_writable.js
@@ -45,6 +45,7 @@ const {
   getHighWaterMark,
   getDefaultHighWaterMark
 } = require('internal/streams/state');
+const assert = require('assert');
 const {
   ERR_INVALID_ARG_TYPE,
   ERR_METHOD_NOT_IMPLEMENTED,
@@ -826,12 +827,16 @@ ObjectDefineProperties(Writable.prototype, {
 const destroy = destroyImpl.destroy;
 Writable.prototype.destroy = function(err, cb) {
   const state = this._writableState;
+
+  // Invoke pending callbacks.
   if (
-    !state.destroyed &&
-    (state.bufferedIndex < state.buffered.length || state[kOnFinished].length)
+    state.bufferedIndex < state.buffered.length ||
+    state[kOnFinished].length
   ) {
+    assert(!state.destroyed);
     process.nextTick(errorBuffer, state);
   }
+
   destroy.call(this, err, cb);
   return this;
 };