Struct actix_http::body::SizedStream

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

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 StdError>> + 'static, 

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

Trait Implementations

impl<S, E> From<SizedStream<S>> for AnyBody where
    S: Stream<Item = Result<Bytes, E>> + 'static,
    E: Into<Box<dyn StdError>> + 'static, 

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

Performs the conversion.

impl<S, E> MessageBody for SizedStream<S> where
    S: Stream<Item = Result<Bytes, E>>,
    E: Into<Box<dyn StdError>> + 'static, 

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Result<Bytes, Self::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

fn size(&self) -> BodySize

Body size hint.

impl<'__pin, S> Unpin for SizedStream<S> where
    __Origin<'__pin, S>: Unpin,