Struct SizedStream

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

Known sized streaming response wrapper.

This body implementation should be used if total size of stream is known. Data is sent as-is without using chunked transfer encoding.

Implementations

impl<S, E> SizedStream<S>

where S: Stream<Item = Result<Bytes, E>>, E: Into<Box<dyn Error>> + 'static,

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

Trait Implementations

impl<S, E> MessageBody for SizedStream<S>

where S: Stream<Item = Result<Bytes, E>>, E: Into<Box<dyn Error>> + 'static,

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

Attempts to pull out the next value of the underlying Stream.

Empty values are skipped to prevent SizedStream’s transmission being ended on a zero-length chunk, but rather proceed until the underlying Stream ends.

type Error = E

The type of error that will be returned if streaming body fails.

fn size(&self) -> BodySize

Body size hint.

fn try_into_bytes(self) -> Result<Bytes, Self>

where Self: Sized,

Try to convert into the complete chunk of body bytes.

fn boxed(self) -> BoxBody

where Self: Sized + 'static,

Wraps this body into a BoxBody.

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

where <PinnedFieldsOfHelperStruct<__Origin<'__pin, S>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,