Struct AsyncContentLengthStream 

pub struct AsyncContentLengthStream<R> { /* private fields */ }

An async stream that reads a Content-Length body in chunks.

This stream first yields any buffered data from the parser, then continues reading from the underlying async reader until the expected length is reached.

Memory Efficiency

Only one chunk is buffered at a time, making this suitable for streaming large request bodies without excessive memory usage.

Implementations

impl<R> AsyncContentLengthStream<R>

where R: AsyncRead + Unpin + Send + Sync + 'static,

pub fn new( initial_buffer: Vec<u8>, reader: R, content_length: usize, config: &StreamingBodyConfig, ) -> Self

Create a new Content-Length stream.

Arguments

• initial_buffer - Any bytes already buffered by the parser
• reader - The async reader for remaining bytes
• content_length - Expected total body size
• config - Streaming configuration

pub fn with_defaults( initial_buffer: Vec<u8>, reader: R, content_length: usize, ) -> Self

Create a Content-Length stream with default config.

pub fn expected_size(&self) -> usize

Returns the expected total size.

pub fn bytes_read(&self) -> usize

Returns the number of bytes read so far.

pub fn remaining(&self) -> usize

Returns the remaining bytes to read.

pub fn is_complete(&self) -> bool

Returns true if the stream is complete.

Trait Implementations

impl<R> Stream for AsyncContentLengthStream<R>

where R: AsyncRead + Unpin + Send + Sync + 'static,

type Item = Result<Vec<u8>, RequestBodyStreamError>

The type of values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.