http: allow passing callbacks for [Incoming,Outgoing]Message#destroy

Fixes: nodejs#28236

lib/_http_incoming.js

@@ -118,11 +118,11 @@ IncomingMessage.prototype._read = function _read(n) {
 // It's possible that the socket will be destroyed, and removed from
 // any messages, before ever calling this.  In that case, just skip
 // it, since something else is destroying this connection anyway.
-IncomingMessage.prototype.destroy = function destroy(error) {
+IncomingMessage.prototype.destroy = function destroy(error, cb) {
   // TODO(ronag): Implement in terms of _destroy
   this.destroyed = true;
   if (this.socket)
-    this.socket.destroy(error);
+    this.socket.destroy(error, cb);
   return this;
 };
 

lib/_http_outgoing.js

@@ -282,17 +282,17 @@ OutgoingMessage.prototype.setTimeout = function setTimeout(msecs, callback) {
 // It's possible that the socket will be destroyed, and removed from
 // any messages, before ever calling this.  In that case, just skip
 // it, since something else is destroying this connection anyway.
-OutgoingMessage.prototype.destroy = function destroy(error) {
+OutgoingMessage.prototype.destroy = function destroy(error, cb) {
   if (this.destroyed) {
     return this;
   }
   this.destroyed = true;
 
   if (this.socket) {
-    this.socket.destroy(error);
+    this.socket.destroy(error, cb);
   } else {
     this.once('socket', function socketDestroyOnConnect(socket) {
-      socket.destroy(error);
+      socket.destroy(error, cb);
     });
   }
 

test/parallel/test-http-incoming-outgoing-destroy-callback.js

@@ -0,0 +1,64 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const http = require('http');
+
+{
+  const server = http.createServer(common.mustCall((req, res) => {
+    res.destroy('xyz', common.mustCall((err) => {
+      assert.strictEqual(err, 'xyz');
+    }));
+    server.close();
+  }));
+  server.listen(0);
+  server.on('listening', common.mustCall(() => {
+    const clientRequest = http.request({
+      port: server.address().port,
+      method: 'GET',
+      path: '/'
+    });
+    clientRequest.on('error', common.mustCall());
+    clientRequest.end();
+  }));
+}
+
+{
+  const server = http.createServer(common.mustCall((req, res) => {
+    req.destroy('xyz', common.mustCall((err) => {
+      assert.strictEqual(err, 'xyz');
+    }));
+    server.close();
+  }));
+  server.listen(0);
+  server.on('listening', common.mustCall(() => {
+    const clientRequest = http.request({
+      port: server.address().port,
+      method: 'GET',
+      path: '/'
+    });
+    clientRequest.on('error', common.mustCall());
+    clientRequest.end();
+  }));
+}
+
+{
+  const server = http.createServer(common.mustCall((req, res) => {
+    res.end();
+  }));
+  server.listen(0);
+  server.on('listening', common.mustCall(() => {
+    const clientRequest = http.request({
+      port: server.address().port,
+      method: 'GET',
+      path: '/'
+    });
+    clientRequest.on('response', common.mustCall((res) => {
+      res.destroy('zyx', common.mustCall((err) => {
+        assert.strictEqual(err, 'zyx');
+      }));
+      server.close();
+    }));
+    clientRequest.on('error', common.mustCall());
+    clientRequest.end();
+  }));
+}