[][src]Trait futures::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<St, F> FusedStream for MapOk<St, F> where
    St: FusedStream
[src]

impl<St, F> FusedStream for MapErr<St, F> where
    St: FusedStream
[src]

Implementors

impl<Fut> FusedStream for FlattenStream<Fut> where
    Fut: Future,
    <Fut as Future>::Output: Stream,
    <Fut as Future>::Output: FusedStream
[src]

impl<Fut> FusedStream for FuturesUnordered<Fut> where
    Fut: Future
[src]

impl<S> FusedStream for Fuse<S>
[src]

impl<St> FusedStream for BufferUnordered<St> where
    St: Stream,
    <St as Stream>::Item: Future
[src]

impl<St> FusedStream for Flatten<St> where
    St: Stream + FusedStream
[src]

impl<St> FusedStream for IntoStream<St> where
    St: FusedStream
[src]

impl<St> FusedStream for Peekable<St> where
    St: Stream
[src]

impl<St> FusedStream for Skip<St> where
    St: FusedStream
[src]

impl<St, E> FusedStream for ErrInto<St, E> where
    St: FusedStream
[src]

impl<St, F> FusedStream for Inspect<St, F> where
    St: Stream + FusedStream
[src]

impl<St, F> FusedStream for Map<St, F> where
    St: FusedStream
[src]

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

impl<St, Fut, F> FusedStream for SkipWhile<St, Fut, F> where
    St: Stream + FusedStream
[src]

impl<St, Fut, F> FusedStream for Then<St, Fut, F> where
    St: FusedStream
[src]

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

impl<St1, St2> FusedStream for Chain<St1, St2> where
    St2: FusedStream
[src]

impl<St1, St2> FusedStream for Select<St1, St2>
[src]

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

impl<T, F, Fut> FusedStream for Unfold<T, F, Fut>
[src]