Struct SizedStream

pub struct SizedStream<S> { /* private fields */ }

Type represent streaming body. This body implementation should be used if total size of stream is known. Data get sent as is without using transfer encoding.

Implementations

impl<S> SizedStream<S>

where S: Stream<Item = Result<Bytes, Error>>,

pub fn new(size: u64, stream: S) -> Self

Trait Implementations

impl<S> From<SizedStream<S>> for Body

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

fn from(s: SizedStream<S>) -> Body

Converts to this type from the input type.

impl<S> MessageBody for SizedStream<S>

where S: Stream<Item = Result<Bytes, Error>>,

fn size(&self) -> BodySize

fn poll_next( &mut self, cx: &mut Context<'_>, ) -> Poll<Option<Result<Bytes, Error>>>

impl<'pin, S> Unpin for SizedStream<S>

where __SizedStream<'pin, S>: Unpin,

impl<S> UnsafeUnpin for SizedStream<S>