Struct AsyncChunkedStream 

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

An async stream that reads a chunked-encoded body.

This stream parses chunked transfer encoding on the fly, yielding decoded chunks as they become available.

Chunked Encoding Format

chunk-size CRLF
chunk-data CRLF
...
0 CRLF
[trailers] CRLF

Implementations

impl<R> AsyncChunkedStream<R>

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

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

Create a new chunked stream.

Arguments

• initial_buffer - Any bytes already buffered by the parser
• reader - The async reader for remaining bytes
• config - Streaming configuration

Panics

Panics if initial_buffer exceeds config.max_size. Use try_new for fallible construction.

pub fn try_new( initial_buffer: Vec<u8>, reader: R, config: &StreamingBodyConfig, ) -> Result<Self, RequestBodyStreamError>

Try to create a new chunked stream, returning error if initial buffer is too large.

Errors

Returns error if initial_buffer.len() exceeds config.max_size.

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

Create a chunked stream with default config.

pub fn bytes_decoded(&self) -> usize

Returns the total decoded bytes so far.

pub fn is_complete(&self) -> bool

Returns true if the stream is complete.

Trait Implementations

impl<R> Stream for AsyncChunkedStream<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.