[−][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

fn is_terminated(&self) -> bool[−]

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<'_, F> FusedStream for &'_ mut F where
    F: FusedStream + ?Sized, [src][−]

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

impl<St, Fut, F> FusedStream for TryFilter<St, Fut, F> where
    F: FnMut(&<St as TryStream>::Ok) -> Fut,
    Fut: Future<Output = bool>,
    St: TryStream + FusedStream, [src][−]

Implementors

impl<A, B> FusedStream for Either<A, B> where
    A: FusedStream,
    B: FusedStream, [src][−]

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

impl<Fut> FusedStream for TryFlattenStream<Fut> where
    Fut: TryFuture,
    <Fut as TryFuture>::Ok: TryStream,
    <Fut as TryFuture>::Ok: FusedStream,
    <<Fut as TryFuture>::Ok as TryStream>::Error == <Fut as TryFuture>::Error, [src][−]

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

impl<Fut, S> FusedStream for FlattenSink<Fut, S> where
    Fut: TryFuture<Ok = S>,
    S: FusedStream, [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 InspectErr<St, F> where
    St: FusedStream + TryStream, [src][−]

impl<St, F> FusedStream for InspectOk<St, F> where
    St: FusedStream + TryStream, [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> FusedStream for Empty<T>[src][−]

impl<T> FusedStream for Pending<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<A, B> FusedStream for Either<A, B> where
    A: FusedStream,
    B: FusedStream, 

impl<Fut, S> FusedStream for FlattenSink<Fut, S> where
    Fut: TryFuture<Ok = S>,
    S: FusedStream, 

impl<Fut> FusedStream for TryFlattenStream<Fut> where
    Fut: TryFuture,
    Fut::Ok: TryStream<Error = Fut::Error> + FusedStream, 

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

impl<T> FusedStream for Empty<T>

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<T> FusedStream for Pending<T>

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: TryStream + FusedStream, F> FusedStream for InspectOk<St, F>

impl<St: TryStream + FusedStream, F> FusedStream for InspectErr<St, F>

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> FusedStream for TryFilter<St, Fut, F> where
    St: TryStream + FusedStream,
    F: FnMut(&St::Ok) -> Fut,
    Fut: Future<Output = bool>, 

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,