MCPcopy Create free account
hub / github.com/Pagghiu/SaneCppLibraries / startResponseStreams

Method startResponseStreams

Libraries/Http/HttpAsyncClient.cpp:540–554  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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
551Result HttpAsyncClient::startResponseStreams()
552{
553 if (responseDecoderActive)
554 {
555 if (responseDecoder->AsyncReadableStream::canStart())
556 {
557 SC_TRY(responseDecoder->AsyncReadableStream::start());

Callers

nothing calls this directly

Calls 1

startBodyStreamMethod · 0.80

Tested by

no test coverage detected