fix: don't leak socket if client is destroyed while connecting

lib/client.js

@@ -21,7 +21,8 @@ const {
   InformationalError,
   BodyTimeoutError,
   HTTPParserError,
-  ResponseExceededMaxSizeError
+  ResponseExceededMaxSizeError,
+  ClientDestroyedError
 } = require('./core/errors')
 const buildConnector = require('./core/connect')
 const {
@@ -1083,6 +1084,11 @@ async function connect (client) {
       })
     })
 
+    if (client.destroyed) {
+      util.destroy(socket.on('error', () => {}), new ClientDestroyedError())
+      return
+    }
+
     if (!llhttpInstance) {
       llhttpInstance = await llhttpPromise
       llhttpPromise = null
@@ -1125,6 +1131,10 @@ async function connect (client) {
     }
     client.emit('connect', client[kUrl], [client])
   } catch (err) {
+    if (client.destroyed) {
+      return
+    }
+
     client[kConnecting] = false
 
     if (channels.connectError.hasSubscribers) {

test/connect-abort.js

@@ -0,0 +1,28 @@
+'use strict'
+
+const { test } = require('tap')
+const { Client } = require('..')
+const { PassThrough } = require('stream')
+
+test(t => {
+  t.plan(2)
+
+  const client = new Client('http://localhost:1234', {
+    connect: (_, cb) => {
+      client.destroy()
+      cb(null, new PassThrough({
+        destroy (err, cb) {
+          t.same(err?.name, 'ClientDestroyedError')
+          cb(null)
+        }
+      }))
+    }
+  })
+
+  client.request({
+    path: '/',
+    method: 'GET'
+  }, (err, data) => {
+    t.same(err?.name, 'ClientDestroyedError')
+  })
+})