Struct ReqBodySender

pub struct ReqBodySender<'conn, S>
where
    S: Stream + Unpin,
{ /* private fields */ }

ReqBodySender handles reading body chunks from the raw payload stream.

This component runs concurrently with request processing to ensure:

1. Body chunks are available when the handler needs them
2. All body data is properly drained from the connection
3. Resources are cleaned up appropriately

The sender maintains an EOF flag to track when the complete body has been read, which is crucial for proper connection handling.

Implementations

impl<S> ReqBodySender<'_, S>

where S: Stream<Item = Result<Message<RequestHeader>, ParseError>> + Unpin,

pub async fn send_body(&mut self) -> Result<(), ParseError>

Streams body chunks from payload stream to ReqBody consumer.

This method runs in a loop, responding to chunk requests from the ReqBody until either:

• The complete body is streamed (EOF)
• An error occurs during streaming

pub async fn skip_body(&mut self)

Drains any remaining body chunks from the payload stream.

This is critical for maintaining HTTP protocol correctness when:

• The handler doesn’t read the complete body
• The connection will be reused for future requests

It ensures the connection is in a clean state for the next request.