Enum Body 

pub enum Body {
    Empty,
    Bytes(Vec<u8>),
    Stream(RequestBodyStream),
}

Request body.

Variants

Empty

Empty body.

Bytes(Vec<u8>)

Bytes body.

Stream(RequestBodyStream)

Streaming body for large uploads.

This variant enables memory-efficient handling of large request bodies by yielding chunks incrementally rather than buffering the entire content.

The stream yields Result<Vec<u8>, RequestBodyStreamError> chunks.

Implementations

impl Body

pub fn into_bytes(self) -> Vec<u8>

Get body as bytes, consuming it.

For Body::Stream, this will panic. Use into_bytes_async() instead for streaming bodies, or check with is_streaming() first.

pub async fn into_bytes_async(self) -> Result<Vec<u8>, RequestBodyStreamError>

Get body as bytes asynchronously, consuming it.

This works for all body types:

• Empty returns an empty Vec
• Bytes returns the bytes
• Stream collects all chunks into a Vec

Errors

Returns an error if the stream encounters an error while reading.

pub fn is_empty(&self) -> bool

Check if body is empty.

pub fn is_streaming(&self) -> bool

Check if body is a streaming body.

pub fn take_stream(self) -> Option<RequestBodyStream>

Take the body stream, if this is a streaming body.

Returns None for Empty and Bytes variants.

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

where S: Stream<Item = Result<Vec<u8>, RequestBodyStreamError>> + Send + Sync + 'static,

Create a streaming body.

pub fn streaming_with_size<S>(stream: S, size: usize) -> Self

where S: Stream<Item = Result<Vec<u8>, RequestBodyStreamError>> + Send + Sync + 'static,

Create a streaming body with a known size.

Trait Implementations

impl Debug for Body

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

Formats the value using the given formatter.