Struct actix_web::dev::SizedStream

pub struct SizedStream<S> where
    S: Unpin,  { /* fields omitted */ }

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>> + Unpin, 

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

Trait Implementations

impl<S> From<SizedStream<S>> for Body where
    S: 'static + Stream<Item = Result<Bytes, Error>> + Unpin, 

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

Performs the conversion.

impl<S> MessageBody for SizedStream<S> where
    S: Stream<Item = Result<Bytes, Error>> + Unpin, 

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

pub fn size(&self) -> BodySize

impl<'pin, S> Unpin for SizedStream<S> where
    S: Unpin,
    __SizedStream<'pin, S>: Unpin,