Struct Fuse 

pub struct Fuse<B> {
    inner: Option<B>,
}

A “fused” Body.

This Body yields Poll::Ready(None) forever after the underlying body yields Poll::Ready(None), or an error Poll::Ready(Some(Err(_))), once.

Bodies should ideally continue to return Poll::Ready(None) indefinitely after the end of the stream is reached. Fuse<B> avoids polling its underlying body B further after the underlying stream as ended, which can be useful for implementation that cannot uphold this guarantee.

This is akin to the functionality that std::iter::Iterator::fuse() provides for Iterators.

Fields

inner: Option<B>

Implementations

impl<B> Fuse<B>

where B: Body,

pub fn new(body: B) -> Self

Returns a fused body.

Trait Implementations

impl<B> Body for Fuse<B>

where B: Body + Unpin,

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 Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<B::Data>, B::Error>>>

Attempt to pull out the next frame of this stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.

impl<B: Debug> Debug for Fuse<B>

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

Formats the value using the given formatter.