Struct BodyStream 

pub struct BodyStream<S, E> { /* private fields */ }

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 S: Stream<Item = Result<Bytes, E>> + Unpin, E: Error,

pub fn new(stream: S) -> Self

Trait Implementations

impl<S, E> Debug for BodyStream<S, E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S, E> From<BodyStream<S, E>> for Body

where S: Stream<Item = Result<Bytes, E>> + Unpin + 'static, E: Error + 'static,

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

Converts to this type from the input type.

impl<S, E> MessageBody for BodyStream<S, E>

where S: Stream<Item = Result<Bytes, E>> + Unpin + 'static, E: Error + 'static,

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

fn size(&self) -> BodySize

Message body size hind