Method completeTransportSetup

Libraries/Http/HttpAsyncClient.cpp:329–377

                               .addListener<HttpAsyncClient, &HttpAsyncClient::onReconnectSocketWritableClosed>(*this);
        if (not added)
        {
            clearReconnectCloseListeners();
            return Result::Error("HttpAsyncClient reconnect socket writable close listener unavailable");
        }
        reconnectClosuresPending++;
    }

    closeConnection(true);
    reconnectCloseInProgress = false;
    return continueReconnectAfterClose();
}

void HttpAsyncClient::onReconnectTransportShutdown(Result result)
{
    if (not reconnectPending)
    {
        return;
    }
    if (not result)
    {
        fail(result);
        return;
    }

    Result closeResult = beginReconnectClose();
    if (not closeResult)
    {
        fail(closeResult);
    }
}

Result HttpAsyncClient::continueReconnectAfterClose()
{
    if (not reconnectPending or reconnectClosuresPending != 0)
    {
        return Result(true);
    }
    reconnectPending              = false;
    reconnectReadableStream       = nullptr;
    reconnectWritableStream       = nullptr;
    reconnectSocketReadableStream = nullptr;
    reconnectSocketWritableStream = nullptr;
    return externalConnector.isValid() ? beginExternalConnection() : beginSocketConnection();
}

void HttpAsyncClient::clearReconnectCloseListeners()
{
    if (reconnectReadableStream != nullptr)
    {
        (void)reconnectReadableStream->eventClose
            .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectReadableClosed>(*this);
    }