Method prepareResponseDecompression

Libraries/Http/HttpAsyncClient.cpp:496–538

    }
    return Result(true);
}

Result HttpAsyncClient::onResponseBodyStreamRead()
{
    if (state == State::StreamingResponse and not response.isBodyComplete())
    {
        connection->getReadableTransportStream().resumeReading();
    }
    return Result(true);
}

Result HttpAsyncClient::prepareResponseDecompression()
{
    responseDecoderActive = false;
    if (responseDecoder == nullptr or response.getBodyFramingKind() == HttpBodyFramingKind::None)
    {
        return Result(true);
    }

    StringSpan contentEncodingHeader;
    if (not response.getHeader("Content-Encoding", contentEncodingHeader))
    {
        return Result(true);
    }

    HttpContentEncoding encoding = HttpContentEncoding::Identity;
    SC_TRY(httpContentEncodingFromHeader(contentEncodingHeader, encoding));
    if (encoding == HttpContentEncoding::Identity)
    {
        return Result(true);
    }

    const ZLibStream::Algorithm algorithm =
        encoding == HttpContentEncoding::GZip ? ZLibStream::DecompressGZip : ZLibStream::DecompressDeflate;
    SC_TRY(responseDecoder->stream.init(algorithm));

    HttpIncomingMessage::BodyStream& rawBody = response.rawBodyStream();
    SC_TRY_MSG((rawBody.eventData.addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseBodyData>(*this)),
               "HttpAsyncClient response decoder data listener limit reached");
    SC_TRY_MSG((rawBody.eventEnd.addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseBodyEnd>(*this)),
               "HttpAsyncClient response decoder end listener limit reached");
    SC_TRY_MSG((rawBody.eventError.addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseError>(*this)),
               "HttpAsyncClient response decoder raw error listener limit reached");
    SC_TRY_MSG((responseDecoder->AsyncReadableStream::eventError
                    .addListener<HttpAsyncClient, &HttpAsyncClient::onCompressedResponseError>(*this)),
               "HttpAsyncClient response decoder readable error listener limit reached");