Method beginRequestSend

Libraries/Http/HttpAsyncClient.cpp:396–456

    SC_TRY_MSG(addedResponseData, "HttpAsyncClient failed to register response listener");
    if (connection->getReadableTransportStream().canStart())
    {
        SC_TRY(connection->getReadableTransportStream().start());
    }
    else
    {
        connection->getReadableTransportStream().resumeReading();
    }
    state = State::Sending;
    return Result(true);
}

Result HttpAsyncClient::beginRequestSend()
{
    request.setWritableStream(connection->getWritableTransportStream());
    request.setHeaderMemory(connection->getHeaderMemory());
    request.reset();
    request.setKeepAlive(currentPreset.keepAlive);
    request.setDefaultHost(currentURL.host);
    request.internalHeadersSentCallback = {[this](AsyncBufferView::ID bufferID) { onHeadersBufferWritten(bufferID); }};

    SC_TRY(request.startRequest(currentPreset.method, currentURL.path));

    switch (currentPreset.bodyMode)
    {
    case RequestPreset::BodyMode::None: break;
    case RequestPreset::BodyMode::Span: SC_TRY(request.setBody(currentPreset.bodySpan)); break;
    case RequestPreset::BodyMode::Stream:
        SC_TRY_MSG(currentPreset.bodyStream != nullptr, "HttpAsyncClient body stream missing");
        request.setBody(*currentPreset.bodyStream, currentPreset.contentLength);
        break;
    case RequestPreset::BodyMode::Multipart:
        SC_TRY_MSG(currentPreset.multipartWriter != nullptr, "HttpAsyncClient multipart writer missing");
        request.setMultipart(*currentPreset.multipartWriter);
        break;
    }

    for (const Header& header : currentPreset.headers)
    {
        SC_TRY(request.addHeader(header.name, header.value));
    }

    if (responseDecoder != nullptr and not request.hasAcceptEncodingHeader())
    {
        SC_TRY(request.addHeader("Accept-Encoding", "gzip, deflate"));
    }

    if (onPrepareRequest.isValid())
    {
        onPrepareRequest(request);
    }

    SC_TRY(validateActiveRequest());

    if (currentPreset.autoSend)
    {
        if (not request.hasSentHeaders())
        {
            SC_TRY(request.sendHeaders());