[−][src]Trait futures_core::stream::FusedStream

pub trait FusedStream {
    fn is_terminated(&self) -> bool;
}
[−]

A Stream or TryStream which tracks whether or not the underlying stream should no longer be polled.

is_terminated will return true if a future should no longer be polled. Usually, this state occurs after poll_next (or try_poll_next) returned Poll::Ready(None). However, is_terminated may also return true if a stream has become inactive and can no longer make progress and should be ignored or dropped rather than being polled again.

Required methods

Returns true if the stream should no longer be polled.

Implementations on Foreign Types

impl<F: ?Sized + FusedStream, '_> FusedStream for &'_ mut F[src][−]

impl<P> FusedStream for Pin<P> where
    P: DerefMut + Unpin,
    P::Target: FusedStream, [src][−]

impl<S: ?Sized + FusedStream> FusedStream for Box<S>[src][−]

Implementors

impl<T> FusedStream for Receiver<T>

impl<T> FusedStream for UnboundedReceiver<T>

impl<Fut> FusedStream for FlattenStream<Fut> where
    Fut: Future,
    Fut::Output: Stream + FusedStream, 

impl<St1, St2: FusedStream> FusedStream for Chain<St1, St2>

impl<St: Stream + FusedStream> FusedStream for Enumerate<St>

impl<St, Fut, F> FusedStream for Filter<St, Fut, F> where
    St: Stream + FusedStream,
    F: FnMut(&St::Item) -> Fut,
    Fut: Future<Output = bool>, 

impl<St, Fut, F, T> FusedStream for FilterMap<St, Fut, F> where
    St: Stream + FusedStream,
    F: FnMut(St::Item) -> Fut,
    Fut: Future<Output = Option<T>>, 

impl<St: Stream + FusedStream> FusedStream for Flatten<St>

impl<S> FusedStream for Fuse<S>

impl<St: Stream + FusedStream, F> FusedStream for Inspect<St, F>

impl<St: FusedStream, F> FusedStream for Map<St, F>

impl<St: Stream> FusedStream for Peekable<St>

impl<St1, St2> FusedStream for Select<St1, St2>

impl<St: FusedStream> FusedStream for Skip<St>

impl<St: Stream + FusedStream, Fut, F> FusedStream for SkipWhile<St, Fut, F>

impl<St: FusedStream, Fut, F> FusedStream for Then<St, Fut, F>

impl<T, F, Fut> FusedStream for Unfold<T, F, Fut>

impl<St1, St2> FusedStream for Zip<St1, St2> where
    St1: Stream,
    St2: Stream, 

impl<St> FusedStream for BufferUnordered<St> where
    St: Stream,
    St::Item: Future, 

impl<Fut: Future> FusedStream for FuturesUnordered<Fut>

impl<St: Stream + Unpin> FusedStream for SelectAll<St>

impl<St: FusedStream, E> FusedStream for ErrInto<St, E>

impl<St: FusedStream> FusedStream for IntoStream<St>

impl<St: FusedStream, F> FusedStream for MapOk<St, F>

impl<St: FusedStream, F> FusedStream for MapErr<St, F>

impl<St, Fut, F, T> FusedStream for TryFilterMap<St, Fut, F> where
    St: TryStream + FusedStream,
    Fut: TryFuture<Ok = Option<T>, Error = St::Error>,
    F: FnMut(St::Ok) -> Fut,