Class AfterWrite

Libraries/Http/HttpAsyncServer.cpp:268–311

Register before starting the body stream, which can synchronously emit buffered body data.

    HttpAsyncServerTransportSetup setup;
    setup.connection = &client;
    setup.eventLoop  = eventLoop;
    setup.complete   = {[this, &client](Result result) { onTransportSetupComplete(client, result); }};
    setup.fail       = {[this, &client](Result result)
                        {
                      if (onError.isValid())
                      {
                          onError(result);
                      }
                      closeAsync(client);
                  }};
    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)
{
    Span<char> readData;
    SC_HTTP_ASSERT_RELEASE(client.buffersPool.getWritableData(bufferID, readData));

    Result headerWrite =
        client.request.writeHeaders(maxHeaderSize, readData, client.getReadableTransportStream(), bufferID);
    if (not headerWrite)
    {
        if (onError.isValid())
        {