aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/node_modules/undici/lib/api/api-connect.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/undici/lib/api/api-connect.js')
-rw-r--r--node_modules/undici/lib/api/api-connect.js14
1 files changed, 9 insertions, 5 deletions
diff --git a/node_modules/undici/lib/api/api-connect.js b/node_modules/undici/lib/api/api-connect.js
index fd2b6ad..f9dbbf6 100644
--- a/node_modules/undici/lib/api/api-connect.js
+++ b/node_modules/undici/lib/api/api-connect.js
@@ -1,7 +1,8 @@
'use strict'
-const { AsyncResource } = require('async_hooks')
-const { InvalidArgumentError, RequestAbortedError, SocketError } = require('../core/errors')
+const assert = require('node:assert')
+const { AsyncResource } = require('node:async_hooks')
+const { InvalidArgumentError, SocketError } = require('../core/errors')
const util = require('../core/util')
const { addSignal, removeSignal } = require('./abort-signal')
@@ -32,10 +33,13 @@ class ConnectHandler extends AsyncResource {
}
onConnect (abort, context) {
- if (!this.callback) {
- throw new RequestAbortedError()
+ if (this.reason) {
+ abort(this.reason)
+ return
}
+ assert(this.callback)
+
this.abort = abort
this.context = context
}
@@ -96,7 +100,7 @@ function connect (opts, callback) {
if (typeof callback !== 'function') {
throw err
}
- const opaque = opts && opts.opaque
+ const opaque = opts?.opaque
queueMicrotask(() => callback(err, { opaque }))
}
}