Struct product_os_http_body_util::BodyStream

pub struct BodyStream<B> { /* private fields */ }

A stream created from a Body.

Implementations

impl<B> BodyStream<B>

pub fn new(body: B) -> BodyStream<B>

Create a new BodyStream.

Trait Implementations

impl<B> Body for BodyStream<B>

where B: Body,

type Data = <B as Body>::Data

Values yielded by the Body.

type Error = <B as Body>::Error

The error type this Body might generate.

fn poll_frame( self: Pin<&mut BodyStream<B>>, cx: &mut Context<'_> ) -> Poll<Option<Result<Frame<<BodyStream<B> as Body>::Data>, <BodyStream<B> as Body>::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

impl<B> Clone for BodyStream<B>

where B: Clone,

fn clone(&self) -> BodyStream<B>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<B> Debug for BodyStream<B>

where B: Debug,

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

Formats the value using the given formatter.

impl<B> Stream for BodyStream<B>

where B: Body,

type Item = Result<Frame<<B as Body>::Data>, <B as Body>::Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut BodyStream<B>>, cx: &mut Context<'_> ) -> Poll<Option<<BodyStream<B> as Stream>::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<B> Copy for BodyStream<B>

where B: Copy,

impl<'__pin, B> Unpin for BodyStream<B>

where __Origin<'__pin, B>: Unpin,