Struct StreamingBody 

pub struct StreamingBody { /* private fields */ }

A streaming body that can be read in chunks

Implementations

impl StreamingBody

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

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

Create a new streaming body from a stream

pub fn from_reader<R>(reader: R, chunk_size: usize) -> Self

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

Create a streaming body from an AsyncRead

pub async fn next_chunk(&mut self) -> Option<Result<Bytes>>

Get the next chunk from the stream

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

Collect all chunks into a single Bytes