(fetchParams, response)
| 60234 | } |
| 60235 | } |
| 60236 | function finalizeResponse(fetchParams, response) { |
| 60237 | fetchParams.request.done = true; |
| 60238 | if (fetchParams.processResponseDone != null) { |
| 60239 | queueMicrotask(() => fetchParams.processResponseDone(response)); |
| 60240 | } |
| 60241 | } |
| 60242 | function fetchFinale(fetchParams, response) { |
| 60243 | if (response.type === "error") { |
| 60244 | response.urlList = [fetchParams.request.urlList[0]]; |
| 60245 | response.timingInfo = createOpaqueTimingInfo({ |
| 60246 | startTime: fetchParams.timingInfo.startTime |
| 60247 | }); |
| 60248 | } |
| 60249 | const processResponseEndOfBody = () => { |
| 60250 | fetchParams.request.done = true; |
| 60251 | if (fetchParams.processResponseEndOfBody != null) { |
| 60252 | queueMicrotask(() => fetchParams.processResponseEndOfBody(response)); |
| 60253 | } |
| 60254 | }; |
| 60255 | if (fetchParams.processResponse != null) { |
| 60256 | queueMicrotask(() => fetchParams.processResponse(response)); |
| 60257 | } |
| 60258 | if (response.body == null) { |
| 60259 | processResponseEndOfBody(); |
| 60260 | } else { |
| 60261 | const identityTransformAlgorithm = (chunk, controller) => { |
| 60262 | controller.enqueue(chunk); |
| 60263 | }; |
| 60264 | const transformStream = new TransformStream3({ |
| 60265 | start() { |
| 60266 | }, |
| 60267 | transform: identityTransformAlgorithm, |
| 60268 | flush: processResponseEndOfBody |
| 60269 | }, { |
| 60270 | size() { |
| 60271 | return 1; |
| 60272 | } |
| 60273 | }, { |
| 60274 | size() { |
| 60275 | return 1; |
| 60276 | } |
| 60277 | }); |
| 60278 | response.body = { stream: response.body.stream.pipeThrough(transformStream) }; |
| 60279 | } |
| 60280 | if (fetchParams.processResponseConsumeBody != null) { |
| 60281 | const processBody = (nullOrBytes) => fetchParams.processResponseConsumeBody(response, nullOrBytes); |
| 60282 | const processBodyError = (failure) => fetchParams.processResponseConsumeBody(response, failure); |
| 60283 | if (response.body == null) { |
| 60284 | queueMicrotask(() => processBody(null)); |
| 60285 | } else { |
| 60286 | return fullyReadBody(response.body, processBody, processBodyError); |
| 60287 | } |
no test coverage detected
searching dependent graphs…