Method onConnected

Libraries/Http/HttpAsyncClient.cpp:269–308

Result HttpAsyncClient::closeConnectionForReconnect()
{
    reconnectPending = true;
    state            = State::Connecting;

    if (transportShutdown.isValid())
    {
        Function<void(Result)> complete = {[this](Result result) { onReconnectTransportShutdown(result); }};
        Result                 shutdown = transportShutdown(move(complete));
        if (not shutdown)
        {
            reconnectPending = false;
            state            = State::Idle;
        }
        return shutdown;
    }
    return beginReconnectClose();
}

Result HttpAsyncClient::beginReconnectClose()
{
    if (not reconnectPending)
        return Result::Error(HttpResultCategory, HttpError::ClientReconnectNotPending);
    reconnectCloseInProgress = true;
    reconnectClosuresPending = 0;

    reconnectReadableStream = &connection->getReadableTransportStream();
    reconnectWritableStream = &connection->getWritableTransportStream();
    reconnectSocketReadableStream =
        reconnectReadableStream != &connection->readableSocketStream ? &connection->readableSocketStream : nullptr;
    reconnectSocketWritableStream =
        reconnectWritableStream != &connection->writableSocketStream ? &connection->writableSocketStream : nullptr;

    if (not reconnectReadableStream->hasBeenDestroyed())
    {
        const bool added = reconnectReadableStream->eventClose
                               .addListener<HttpAsyncClient, &HttpAsyncClient::onReconnectReadableClosed>(*this);
        if (not added)
        {
            clearReconnectCloseListeners();
            return Result::Error(HttpResultCategory, HttpError::ClientReconnectListenerUnavailable);
        }
        reconnectClosuresPending++;
    }