diff options
Diffstat (limited to 'node_modules/undici/lib/api/api-connect.js')
| -rw-r--r-- | node_modules/undici/lib/api/api-connect.js | 14 |
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 })) } } |
