stream: don't emit prefinish after error or close

PR-URL: #39332
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>

lib/internal/streams/writable.js

@@ -654,7 +654,9 @@ function needFinish(state) {
           !state.errored &&
           state.buffered.length === 0 &&
           !state.finished &&
-          !state.writing);
+          !state.writing &&
+          !state.errorEmitted &&
+          !state.closeEmitted);
 }
 
 function callFinal(stream, state) {
@@ -685,7 +687,7 @@ function callFinal(stream, state) {
         then.call(
           result,
           function() {
-            if (state.prefinished)
+            if (state.prefinished || !needFinish(state))
               return;
             state.prefinish = true;
             process.nextTick(() => stream.emit('prefinish'));
@@ -735,10 +737,6 @@ function finishMaybe(stream, state, sync) {
 
 function finish(stream, state) {
   state.pendingcb--;
-  // TODO (ronag): Unify with needFinish.
-  if (state.errorEmitted || state.closeEmitted)
-    return;
-
   state.finished = true;
 
   const onfinishCallbacks = state[kOnFinished].splice(0);

test/parallel/test-stream-writable-final-destroy.js

@@ -0,0 +1,21 @@
+'use strict';
+const common = require('../common');
+
+const { Writable } = require('stream');
+
+{
+  const w = new Writable({
+    write(chunk, encoding, callback) {
+      callback(null);
+    },
+    final(callback) {
+      queueMicrotask(callback);
+    }
+  });
+  w.end();
+  w.destroy();
+
+  w.on('prefinish', common.mustNotCall());
+  w.on('finish', common.mustNotCall());
+  w.on('close', common.mustCall());
+}