(body, processBody, processBodyError)
| 50935 | } |
| 50936 | case "key+value": { |
| 50937 | result = pair; |
| 50938 | break; |
| 50939 | } |
| 50940 | } |
| 50941 | return { value: result, done: false }; |
| 50942 | } |
| 50943 | async function fullyReadBody(body, processBody, processBodyError) { |
| 50944 | const successSteps = processBody; |
| 50945 | const errorSteps = processBodyError; |
| 50946 | let reader; |
| 50947 | try { |
| 50948 | reader = body.stream.getReader(); |
| 50949 | } catch (e3) { |
| 50950 | errorSteps(e3); |
| 50951 | return; |
| 50952 | } |
| 50953 | try { |
| 50954 | const result = await readAllBytes(reader); |
| 50955 | successSteps(result); |
| 50956 | } catch (e3) { |
no test coverage detected
searching dependent graphs…