(opts, callback)
| 10684 | }); |
| 10685 | |
| 10686 | // |
| 10687 | var require_api_upgrade = __commonJS({ |
| 10688 | ""(exports, module) { |
| 10689 | "use strict"; |
| 10690 | var { InvalidArgumentError, SocketError } = require_errors(); |
| 10691 | var { AsyncResource } = __require("async_hooks"); |
| 10692 | var util = require_util(); |
| 10693 | var { addSignal, removeSignal } = require_abort_signal(); |
| 10694 | var assert = __require("assert"); |
| 10695 | var UpgradeHandler = class extends AsyncResource { |
| 10696 | constructor(opts, callback) { |
| 10697 | if (!opts || typeof opts !== "object") { |
| 10698 | throw new InvalidArgumentError("invalid opts"); |
| 10699 | } |
| 10700 | if (typeof callback !== "function") { |
| 10701 | throw new InvalidArgumentError("invalid callback"); |
| 10702 | } |
| 10703 | const { signal, opaque, responseHeaders } = opts; |
| 10704 | if (signal && typeof signal.on !== "function" && typeof signal.addEventListener !== "function") { |
| 10705 | throw new InvalidArgumentError("signal must be an EventEmitter or EventTarget"); |
| 10706 | } |
| 10707 | super("UNDICI_UPGRADE"); |
| 10708 | this.responseHeaders = responseHeaders || null; |
| 10709 | this.opaque = opaque || null; |
| 10710 | this.callback = callback; |
nothing calls this directly
no test coverage detected