fixup: always register eos

ronag · ronag · commit 81de706be6d4 · 2020-02-29T11:58:41.000+01:00
diff --git a/lib/internal/streams/destroy.js b/lib/internal/streams/destroy.js
@@ -1,5 +1,6 @@
 'use strict';
 
+const { once } = require('internal/util');
 let eos;
 
 function destroy(err, cb) {
@@ -11,13 +12,17 @@ function destroy(err, cb) {
     err = null;
   }
 
+  if (typeof cb === 'function') {
+    // TODO(ronag): Remove once cb is invoked only through eos.
+    cb = once(cb);
+
+    if (!eos) eos = require('internal/streams/end-of-stream');
+    eos(this, (err) => {
+      cb(err && err.code !== 'ERR_STREAM_PREMATURE_CLOSE' ? err : undefined);
+    });
+  }
+
   if ((w && w.destroyed) || (r && r.destroyed)) {
-    if (typeof cb === 'function') {
-      if (!eos) eos = require('internal/streams/end-of-stream');
-      eos(this, (err) => {
-        cb(err && err.code !== 'ERR_STREAM_PREMATURE_CLOSE' ? err : undefined);
-      });
-    }
     return this;
   }
 
