Struct actix_web::body::BodyStream

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

Streaming response wrapper.

Response does not contain Content-Length header and appropriate transfer encoding is used.

Implementations

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

pub fn new(stream: S) -> BodyStream<S>

Trait Implementations

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

pub fn from(s: BodyStream<S>) -> AnyBody

Performs the conversion.

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

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

type Error = E

pub fn size(&self) -> BodySize

Body size hint.

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