Method finalizeResponse

Libraries/Http/HttpAsyncClient.cpp:850–898

}

void HttpAsyncClient::onCompressedResponseBodyData(AsyncBufferView::ID bufferID)
{
    SC_HTTP_ASSERT_RELEASE(responseDecoder != nullptr);
    Result writeResult = responseDecoder->AsyncWritableStream::write(
        bufferID, {[this](AsyncBufferView::ID writtenBufferID) { onCompressedResponseBodyWritten(writtenBufferID); }});
    if (not writeResult)
    {
        fail(writeResult);
    }
}

void HttpAsyncClient::onCompressedResponseBodyWritten(AsyncBufferView::ID) {}

void HttpAsyncClient::onCompressedResponseBodyEnd()
{
    SC_HTTP_ASSERT_RELEASE(responseDecoder != nullptr);
    detachResponseDecompression();
    responseDecoder->AsyncWritableStream::end();
}

void HttpAsyncClient::onCompressedResponseError(Result result) { fail(result); }

void HttpAsyncClient::onHeadersBufferWritten(AsyncBufferView::ID)
{
    if (currentRequest == nullptr)
    {
        return;
    }
    if (currentRequest->getBodyType() == HttpAsyncClientRequest::BodyType::Stream)
    {
        connection->pipeline.source        = currentRequest->getBodyStream();
        connection->pipeline.transforms[0] = currentRequest->getBodyTransform();
        connection->pipeline.transforms[1] = nullptr;
        connection->pipeline.sinks[0]      = &currentRequest->getWritableStream();
        connection->pipeline.sinks[1]      = nullptr;

        Result res = connection->pipeline.pipe();
        if (res)
        {
            res = connection->pipeline.start();
        }
        if (not res)
        {
            fail(res);
        }
    }
    else if (currentRequest->getBodyType() == HttpAsyncClientRequest::BodyType::Span)
    {
        Result writeResult = connection->getWritableTransportStream().write(
            AsyncBufferView(currentRequest->getBodySpan()),
            {[this](AsyncBufferView::ID) { connection->getWritableTransportStream().end(); }});
        if (not writeResult)