Struct ntex::http::body::BoxedBodyStream

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

Type represent streaming body. Response does not contain content-length header and appropriate transfer encoding is used.

Implementations

impl<S> BoxedBodyStream<S> where
    S: Stream<Item = Result<Bytes, Box<dyn Error>>> + Unpin, 

pub fn new(stream: S) -> Self

Trait Implementations

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

pub fn size(&self) -> BodySize

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

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

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