[−][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<P> FusedStream for Pin<P> where
    P: DerefMut + Unpin,
    <P as Deref>::Target: FusedStream, [src][−]

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

impl<'_, F> FusedStream for &'_ mut F where
    F: FusedStream + ?Sized, [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 Enumerate<St> where
    St: Stream + FusedStream, [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 SelectAll<St> where
    St: Unpin + 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, F> FusedStream for MapErr<St, F> where
    St: FusedStream, [src][−]

impl<St, F> FusedStream for MapOk<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<St, Fut, F, T> FusedStream for TryFilterMap<St, Fut, F> where
    F: FnMut(<St as TryStream>::Ok) -> Fut,
    Fut: TryFuture<Ok = Option<T>, Error = <St as TryStream>::Error>,
    St: TryStream + 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> FusedStream for Receiver<T>[src][−]

impl<T> FusedStream for UnboundedReceiver<T>[src][−]

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

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,