Method onHeadersBufferWritten

Libraries/Http/HttpAsyncClient.cpp:598–687

}

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)
        {
            fail(writeResult);
        }
    }
    else if (currentRequest->getBodyType() == HttpAsyncClientRequest::BodyType::Multipart)
    {
        static constexpr const char* HeaderSpaceFinished = "HttpAsyncClient header space is finished";

        const HttpMultipartWriter& writer = *currentRequest->getMultipartWriter();
        HttpFixedBufferWriter      bodyWriter;
        bodyWriter.reset(connection->getHeaderMemory());
        const auto appendMultipartBody = [&]() -> Result
        {
            for (size_t idx = 0; idx < writer.getNumParts(); ++idx)
            {
                const HttpMultipartWriter::Part& part = writer.getPart(idx);
                SC_TRY(bodyWriter.appendLiteral("--", HeaderSpaceFinished));