(input, init = void 0)
| 13895 | } = require_constants3(); |
| 13896 | var EE = __require("events"); |
| 13897 | var { Readable, pipeline, finished } = __require("stream"); |
| 13898 | var { addAbortListener, isErrored, isReadable, bufferToLowerCasedHeaderName } = require_util(); |
| 13899 | var { dataURLProcessor, serializeAMimeType, minimizeSupportedMimeType } = require_data_url(); |
| 13900 | var { getGlobalDispatcher } = require_global2(); |
| 13901 | var { webidl } = require_webidl(); |
| 13902 | var { STATUS_CODES } = __require("http"); |
| 13903 | var GET_OR_HEAD = ["GET", "HEAD"]; |
| 13904 | var defaultUserAgent = typeof __UNDICI_IS_NODE__ !== "undefined" || typeof esbuildDetection !== "undefined" ? "node" : "undici"; |
| 13905 | var resolveObjectURL; |
| 13906 | var Fetch = class extends EE { |
| 13907 | constructor(dispatcher) { |
| 13908 | super(); |
| 13909 | this.dispatcher = dispatcher; |
| 13910 | this.connection = null; |
| 13911 | this.dump = false; |
| 13912 | this.state = "ongoing"; |
| 13913 | } |
| 13914 | terminate(reason) { |
| 13915 | var _a; |
| 13916 | if (this.state !== "ongoing") { |
| 13917 | return; |
| 13918 | } |
| 13919 | this.state = "terminated"; |
| 13920 | (_a = this.connection) == null ? void 0 : _a.destroy(reason); |
| 13921 | this.emit("terminated", reason); |
| 13922 | } |
| 13923 | // https://fetch.spec.whatwg.org/#fetch-controller-abort |
| 13924 | abort(error) { |
| 13925 | var _a; |
| 13926 | if (this.state !== "ongoing") { |
| 13927 | return; |
| 13928 | } |
| 13929 | this.state = "aborted"; |
| 13930 | if (!error) { |
| 13931 | error = new DOMException("The operation was aborted.", "AbortError"); |
| 13932 | } |
| 13933 | this.serializedAbortReason = error; |
| 13934 | (_a = this.connection) == null ? void 0 : _a.destroy(error); |
| 13935 | this.emit("terminated", error); |
| 13936 | } |
| 13937 | }; |
| 13938 | function handleFetchDone(response) { |
| 13939 | finalizeAndReportTiming(response, "fetch"); |
| 13940 | } |
| 13941 | function fetch(input, init = void 0) { |
| 13942 | var _a; |
| 13943 | webidl.argumentLengthCheck(arguments, 1, "globalThis.fetch"); |
| 13944 | let p = createDeferredPromise(); |
| 13945 | let requestObject; |
| 13946 | try { |
| 13947 | requestObject = new Request(input, init); |
| 13948 | } catch (e) { |
| 13949 | p.reject(e); |
| 13950 | return p.promise; |
| 13951 | } |
| 13952 | const request = requestObject[kState]; |
| 13953 | if (requestObject.signal.aborted) { |
| 13954 | abortFetch(p, request, null, requestObject.signal.reason); |
no test coverage detected