nodejs
diff --git a/Collapse file
‎lib/internal/streams/destroy.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/destroy.js
+16-22Lines changed: 16 additions & 22 deletions b/Collapse file
‎lib/internal/streams/destroy.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/destroy.js
+16-22Lines changed: 16 additions & 22 deletions
@@ -8,6 +8,20 @@ const { Symbol } = primordials;
 const kDestroy = Symbol('kDestroy');
 const kConstruct = Symbol('kConstruct');
 
+function checkError(err, w, r) {
+  if (err) {
+    // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364
+    err.stack;
+
+    if (w && !w.errored) {
+      w.errored = err;
+    }
+    if (r && !r.errored) {
+      r.errored = err;
+    }
+  }
+}
+
 // Backwards compat. cb() is undocumented and unused in core but
 // unfortunately might be used by modules.
 function destroy(err, cb) {
@@ -24,20 +38,10 @@ function destroy(err, cb) {
     return this;
   }
 
-  if (err) {
-    // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364
-    err.stack;
-
-    if (w && !w.errored) {
-      w.errored = err;
-    }
-    if (r && !r.errored) {
-      r.errored = err;
-    }
-  }
 
   // We set destroyed to true before firing error callbacks in order
   // to make it re-entrance safe in case destroy() is called within callbacks
+  checkError(err, w, r);
 
   if (w) {
     w.destroyed = true;
@@ -66,17 +70,7 @@ function _destroy(self, err, cb) {
 
     called = true;
 
-    if (err) {
-      // Avoid V8 leak, https://github.com/nodejs/node/pull/34103#issuecomment-652002364
-      err.stack;
-
-      if (w && !w.errored) {
-        w.errored = err;
-      }
-      if (r && !r.errored) {
-        r.errored = err;
-      }
-    }
+    checkError(err, w, r);
 
     if (w) {
       w.closed = true;