({
request: request3,
processRequestBodyChunkLength,
processRequestEndOfBody,
processResponse,
processResponseEndOfBody,
processResponseConsumeBody,
useParallelQueue = false,
dispatcher
// undici
})
| 60003 | response.body.stream.cancel(error).catch((err) => { |
| 60004 | if (err.code === "ERR_INVALID_STATE") { |
| 60005 | return; |
| 60006 | } |
| 60007 | throw err; |
| 60008 | }); |
| 60009 | } |
| 60010 | } |
| 60011 | function fetching({ |
| 60012 | request: request3, |
| 60013 | processRequestBodyChunkLength, |
| 60014 | processRequestEndOfBody, |
| 60015 | processResponse, |
| 60016 | processResponseEndOfBody, |
| 60017 | processResponseConsumeBody, |
| 60018 | useParallelQueue = false, |
| 60019 | dispatcher |
| 60020 | // undici |
| 60021 | }) { |
| 60022 | let taskDestination = null; |
| 60023 | let crossOriginIsolatedCapability = false; |
| 60024 | if (request3.client != null) { |
| 60025 | taskDestination = request3.client.globalObject; |
| 60026 | crossOriginIsolatedCapability = request3.client.crossOriginIsolatedCapability; |
| 60027 | } |
| 60028 | const currenTime = coarsenedSharedCurrentTime(crossOriginIsolatedCapability); |
| 60029 | const timingInfo = createOpaqueTimingInfo({ |
| 60030 | startTime: currenTime |
| 60031 | }); |
| 60032 | const fetchParams = { |
| 60033 | controller: new Fetch(dispatcher), |
| 60034 | request: request3, |
| 60035 | timingInfo, |
| 60036 | processRequestBodyChunkLength, |
| 60037 | processRequestEndOfBody, |
| 60038 | processResponse, |
| 60039 | processResponseConsumeBody, |
| 60040 | processResponseEndOfBody, |
| 60041 | taskDestination, |
| 60042 | crossOriginIsolatedCapability |
| 60043 | }; |
| 60044 | assert2(!request3.body || request3.body.stream); |
| 60045 | if (request3.window === "client") { |
| 60046 | request3.window = request3.client?.globalObject?.constructor?.name === "Window" ? request3.client : "no-window"; |
| 60047 | } |
| 60048 | if (request3.origin === "client") { |
| 60049 | request3.origin = request3.client?.origin; |
| 60050 | } |
| 60051 | if (request3.policyContainer === "client") { |
| 60052 | if (request3.client != null) { |
| 60053 | request3.policyContainer = clonePolicyContainer( |
| 60054 | request3.client.policyContainer |
| 60055 | ); |
| 60056 | } else { |
| 60057 | request3.policyContainer = makePolicyContainer(); |
| 60058 | } |
| 60059 | } |
| 60060 | if (!request3.headersList.contains("accept")) { |
| 60061 | const value = "*/*"; |
| 60062 | request3.headersList.append("accept", value); |
no test coverage detected
searching dependent graphs…