MCPcopy Create free account
hub / github.com/angular/dev-infra / fetch

Function fetch

github-actions/saucelabs/set-saucelabs-env.js:13897–13954  ·  view source on GitHub ↗
(input, init = void 0)

Source from the content-addressed store, hash-verified

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);

Callers 6

getNpmPackageIntegrityFunction · 0.50
getNodeJsRepositoriesFunction · 0.50
index.tsFile · 0.50
test.mjsFile · 0.50

Calls 6

createDeferredPromiseFunction · 0.70
abortFetchFunction · 0.70
addAbortListenerFunction · 0.70
fetchingFunction · 0.70
abortMethod · 0.45
derefMethod · 0.45

Tested by

no test coverage detected