Method onStreamReceive

Libraries/Http/HttpAsyncServer.cpp:197–324

    // Only reactivate asyncAccept if there are available clients (otherwise it's being reactivated in closeAsync)
    result.reactivateRequest(connections.getNumActiveConnections() < connections.getNumTotalConnections());
}

Result HttpAsyncServer::beginHttpConnection(HttpConnection& client)
{
    client.response.setWritableStream(client.getWritableTransportStream());

    EventDataListener dataListener{*this, client};
    SC_TRY_MSG(client.getReadableTransportStream().eventData.addListener(dataListener),
               "HttpAsyncServer readable data listener unavailable");
    if (client.getReadableTransportStream().canStart())
    {
        SC_TRY(client.getReadableTransportStream().start());
    }
    else
    {
        client.getReadableTransportStream().resumeReading();
    }
    return Result(true);
}

Result HttpAsyncServer::beginTransportConnection(HttpConnection& client)
{
    if (not transportSetup.isValid())
    {
        return beginHttpConnection(client);
    }

    HttpAsyncServerTransportSetup setup;
    setup.connection = &client;
    setup.eventLoop  = eventLoop;
    setup.complete   = {[this, &client](Result result) { onTransportSetupComplete(client, result); }};
    return transportSetup(setup);
}

void HttpAsyncServer::onTransportSetupComplete(HttpConnection& client, Result result)
{
    if (not result)
    {
        if (onError.isValid())
        {
            onError(result);
        }
        closeAsync(client);
        return;
    }

    Result setup = beginHttpConnection(client);
    if (not setup)
    {
        if (onError.isValid())
        {
            onError(setup);
        }
        closeAsync(client);
    }
}

void HttpAsyncServer::onStreamReceive(HttpConnection& client, AsyncBufferView::ID bufferID)