Method onRequestBodyData

Libraries/Http/HttpAsyncServer.cpp:326–358

        // 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);
        }