Struct RequestStream 

pub struct RequestStream { /* private fields */ }

A streamed request body (uploads, WebSocket-inbound relay). Symmetric to ResponseStream: carries an optional trailers slot a chunked decoder populates at body-end (HTTP/1.1 request trailers, RFC 7230 §4.1.2). Request::body_bytes folds those into Request.headers after draining — “request trailers fold into headers at chunked-decode end”.

Implementations

impl RequestStream

pub fn new<S>(stream: S) -> Self

where S: Stream<Item = Result<Bytes, ProximaError>> + Send + 'static,

pub fn from_chunk_stream(stream: ChunkStream) -> Self

pub fn with_trailers_slot(self, slot: TrailersSlot) -> Self

Attach a trailers slot a chunked decoder populates at body-end.

pub fn trailers(&self) -> Option<HeaderList>

Read captured trailers, if any. None until a stream-end producer populates the slot.

pub fn trailers_slot(&self) -> Option<&TrailersSlot>

Borrow the trailers slot — handed to a producer (the chunked decoder pump) before the stream completes.

pub fn into_chunk_stream(self) -> ChunkStream

pub fn chunk_stream_mut(&mut self) -> &mut ChunkStream

pub async fn collect(self) -> Result<Bytes, ProximaError>

Drain to a single Bytes.

Trait Implementations

impl Debug for RequestStream

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.