Struct actix_web::body::BodyStream

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

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

Implementations

impl<S, E> BodyStream<S, E> where
    E: Into<Error>,
    S: Stream<Item = Result<Bytes, E>> + Unpin, 

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

Trait Implementations

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

fn from(s: BodyStream<S, E>) -> Body

Performs the conversion.

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

fn size(&self) -> BodySize

fn poll_next(
    self: Pin<&mut BodyStream<S, E>>,
    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 BodyStream's transmission being ended on a zero-length chunk, but rather proceed until the underlying Stream ends.

impl<'pin, S, E> Unpin for BodyStream<S, E> where
    S: Unpin,
    __BodyStream<'pin, S, E>: Unpin, 

impl<S, E> UnsafeUnpin for BodyStream<S, E> where
    S: Unpin,