(stream4)
| 79113 | const inputStream = response.body.pipeThrough(new TextDecoderStream("utf8", { fatal: true })); |
| 79114 | const responseStream = getResponseStream(inputStream); |
| 79115 | const [stream1, stream22] = responseStream.tee(); |
| 79116 | return { |
| 79117 | stream: generateResponseSequence(stream1), |
| 79118 | response: getResponsePromise(stream22) |
| 79119 | }; |
| 79120 | } |
| 79121 | async function getResponsePromise(stream4) { |
| 79122 | const allResponses = []; |
| 79123 | const reader = stream4.getReader(); |
| 79124 | while (true) { |
| 79125 | const { done, value } = await reader.read(); |
| 79126 | if (done) { |
| 79127 | return addHelpers(aggregateResponses(allResponses)); |
| 79128 | } |
no test coverage detected
searching dependent graphs…