| 538 | "HttpAsyncClient response decoder raw error listener limit reached"); |
| 539 | SC_TRY_MSG((responseDecoder->AsyncReadableStream::eventError |
| 540 | .addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseError>(*this)), |
| 541 | "HttpAsyncClient response decoder readable error listener limit reached"); |
| 542 | SC_TRY_MSG((responseDecoder->AsyncWritableStream::eventError |
| 543 | .addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseError>(*this)), |
| 544 | "HttpAsyncClient response decoder writable error listener limit reached"); |
| 545 | |
| 546 | response.attachReadableStream(*responseDecoder); |
| 547 | responseDecoderActive = true; |
| 548 | return Result(true); |
| 549 | } |
| 550 | |
| 551 | Result HttpAsyncClient::startResponseStreams() |
| 552 | { |
| 553 | if (responseDecoderActive) |
| 554 | { |
| 555 | if (responseDecoder->AsyncReadableStream::canStart()) |
| 556 | { |
| 557 | SC_TRY(responseDecoder->AsyncReadableStream::start()); |
nothing calls this directly
no test coverage detected