Class AfterWrite

Libraries/Http/HttpAsyncServer.cpp:268–311

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

        }
        closeAsync(client);
        return;
    }
    else if (client.request.hasReceivedHeaders())
    {
        client.response.grabUnusedHeaderMemory(client.request);
        client.response.reset();

        // Both with and without body we should stop listening to data events
        SC_HTTP_ASSERT_RELEASE(
            client.getReadableTransportStream().eventData.removeListener(EventDataListener{*this, client}));
        if (client.requestCount > 0)
        {
            SC_HTTP_ASSERT_RELEASE(
                client.getReadableTransportStream().eventEnd.removeListener(EventEndListener{*this, client}));
        }
        Result prepareBody =
            client.request.prepareBodyStream(client.buffersPool,
                                             {[&client]() -> Result
                                              {
                                                  if (not client.request.isBodyComplete())
                                                  {
                                                      client.getReadableTransportStream().resumeReading();
                                                  }
                                                  return Result(true);
                                              }},
                                             false);
        if (not prepareBody)
        {
            if (onError.isValid())
            {
                onError(prepareBody);
            }
            closeAsync(client);
            return;
        }

        if (client.request.getBodyFramingKind() == HttpBodyFramingKind::Chunked or
            client.request.getBodyFramingKind() == HttpBodyFramingKind::ContentLength)
        {
            const bool addedBodyData =
                client.getReadableTransportStream().eventData.addListener(EventBodyDataListener{*this, client});
            SC_HTTP_ASSERT_RELEASE(addedBodyData);
        }

        onRequest(client);

        if (client.isWebSocketUpgraded())