Struct StreamDataBody 

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

Bidirectional adapter between Stream and Body:

• When the inner value implements Body, this type implements Stream yielding Result<Body::Data, Body::Error>. Trailer frames are ignored and treated as end of stream.
• When the inner value implements Stream, this type implements Body wrapping each streamed item into Frame::Data.

Implementations

impl<T> StreamDataBody<T>

pub fn new(value: T) -> Self

Trait Implementations

impl<S, T, E> Body for StreamDataBody<S>

where S: Stream<Item = Result<T, E>>,

type Data = T

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 StreamDataBody<T>

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

Formats the value using the given formatter.

impl<B> Stream for StreamDataBody<B>

where B: Body,

type Item = Result<<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 StreamDataBody<T>

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