(response, initiatorType = "other")
| 13953 | if (requestObject.signal.aborted) { |
| 13954 | abortFetch(p, request, null, requestObject.signal.reason); |
| 13955 | return p.promise; |
| 13956 | } |
| 13957 | const globalObject = request.client.globalObject; |
| 13958 | if (((_a = globalObject == null ? void 0 : globalObject.constructor) == null ? void 0 : _a.name) === "ServiceWorkerGlobalScope") { |
| 13959 | request.serviceWorkers = "none"; |
| 13960 | } |
| 13961 | let responseObject = null; |
| 13962 | let locallyAborted = false; |
| 13963 | let controller = null; |
| 13964 | addAbortListener( |
| 13965 | requestObject.signal, |
| 13966 | () => { |
| 13967 | locallyAborted = true; |
| 13968 | assert(controller != null); |
| 13969 | controller.abort(requestObject.signal.reason); |
| 13970 | const realResponse = responseObject == null ? void 0 : responseObject.deref(); |
| 13971 | abortFetch(p, request, realResponse, requestObject.signal.reason); |
| 13972 | } |
| 13973 | ); |
| 13974 | const processResponse = (response) => { |
| 13975 | if (locallyAborted) { |
| 13976 | return; |
| 13977 | } |
| 13978 | if (response.aborted) { |
| 13979 | abortFetch(p, request, responseObject, controller.serializedAbortReason); |
| 13980 | return; |
| 13981 | } |
| 13982 | if (response.type === "error") { |
| 13983 | p.reject(new TypeError("fetch failed", { cause: response.error })); |
| 13984 | return; |
| 13985 | } |
| 13986 | responseObject = new WeakRef(fromInnerResponse(response, "immutable")); |
| 13987 | p.resolve(responseObject.deref()); |
| 13988 | p = null; |
| 13989 | }; |
| 13990 | controller = fetching({ |
no test coverage detected