Struct product_os_http_body_util::StreamBody

pub struct StreamBody<S> { /* private fields */ }

A body created from a Stream.

Implementations

impl<S> StreamBody<S>

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

Create a new StreamBody.

Trait Implementations

impl<S, D, E> Body for StreamBody<S>

where S: Stream<Item = Result<Frame<D>, E>>, D: Buf,

type Data = D

Values yielded by the Body.

type Error = E

The error type this Body might generate.

fn poll_frame( self: Pin<&mut StreamBody<S>>, cx: &mut Context<'_> ) -> Poll<Option<Result<Frame<<StreamBody<S> as Body>::Data>, <StreamBody<S> 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<S> Clone for StreamBody<S>

where S: Clone,

fn clone(&self) -> StreamBody<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> Debug for StreamBody<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S> Stream for StreamBody<S>

where S: Stream,

type Item = <S as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut StreamBody<S>>, cx: &mut Context<'_> ) -> Poll<Option<<StreamBody<S> 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<S> Copy for StreamBody<S>

where S: Copy,

impl<'__pin, S> Unpin for StreamBody<S>

where __Origin<'__pin, S>: Unpin,