Method onConnected

Libraries/Http/HttpAsyncClient.cpp:269–308

{
    if (not result.isValid())
    {
        fail(result.isValid());
        return;
    }

    Result readInit = connection->readableSocketStream.init(connection->buffersPool, *eventLoop, connection->socket);
    if (not readInit)
    {
        fail(readInit);
        return;
    }
    Result writeInit = connection->writableSocketStream.init(connection->buffersPool, *eventLoop, connection->socket);
    if (not writeInit)
    {
        fail(writeInit);
        return;
    }
    connection->resetTransportStreams();

    if (transportSetup.isValid())
    {
        HttpAsyncClientTransportSetup setup;
        setup.connection = connection;
        setup.eventLoop  = eventLoop;
        setup.url        = &currentURL;
        setup.complete   = {[this](Result setupResult) { completeTransportSetup(setupResult); }};

        Result nativeSocket =
            connection->socket.get(setup.nativeSocket, Result::Error("HttpAsyncClient invalid socket"));
        if (not nativeSocket)
        {
            fail(nativeSocket);
            return;
        }

        Result setupResult = transportSetup(setup);
        if (not setupResult)
        {
            fail(setupResult);
        }
        return;
    }