Struct StreamBody 

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

Bidirectional adapter between Stream and Body at the Frame level:

• When the inner value implements Body, this type implements Stream yielding Result<Frame<Body::Data>, Body::Error>.
• When the inner value implements Stream, this type implements Body forwarding each Result<Frame<D>, E> frame as-is.

Implementations

impl<T> StreamBody<T>

pub fn new(value: T) -> Self

Trait Implementations

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

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

type Data = D

The payload data type yielded by Frame::Data variants.

type Error = E

The error type that can occur while producing frames.

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

Attempt to pull the next frame from the body.

fn is_end_stream(&self) -> bool

Indicates whether the body has been fully consumed.

fn size_hint(&self) -> SizeHint

Returns a hint about the total size of the remaining Frame::Data payload.

impl<T: Debug> Debug for StreamBody<T>

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

Formats the value using the given formatter.

impl<B> Stream for StreamBody<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 Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::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<'__pin, T> Unpin for StreamBody<T>

where PinnedFieldsOf<__Origin<'__pin, T>>: Unpin,