Method beginRequestSend

Libraries/Http/HttpAsyncClient.cpp:396–456

            .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectSocketWritableClosed>(*this);
    }
    reconnectClosuresPending      = 0;
    reconnectCloseInProgress      = false;
    reconnectPending              = false;
    reconnectReadableStream       = nullptr;
    reconnectWritableStream       = nullptr;
    reconnectSocketReadableStream = nullptr;
    reconnectSocketWritableStream = nullptr;
}

void HttpAsyncClient::onReconnectReadableClosed()
{
    if (reconnectReadableStream != nullptr)
    {
        (void)reconnectReadableStream->eventClose
            .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectReadableClosed>(*this);
    }
    if (reconnectClosuresPending > 0)
    {
        reconnectClosuresPending--;
    }
    if (not reconnectCloseInProgress)
    {
        Result result = continueReconnectAfterClose();
        if (not result)
        {
            fail(result);
        }
    }
}

void HttpAsyncClient::onReconnectWritableClosed()
{
    if (reconnectWritableStream != nullptr)
    {
        (void)reconnectWritableStream->eventClose
            .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectWritableClosed>(*this);
    }
    if (reconnectClosuresPending > 0)
    {
        reconnectClosuresPending--;
    }
    if (not reconnectCloseInProgress)
    {
        Result result = continueReconnectAfterClose();
        if (not result)
        {
            fail(result);
        }
    }
}

void HttpAsyncClient::onReconnectSocketReadableClosed()
{
    if (reconnectSocketReadableStream != nullptr)
    {
        (void)reconnectSocketReadableStream->eventClose
            .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectSocketReadableClosed>(*this);
        reconnectSocketReadableStream = nullptr;