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

[+] Show declaration

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.

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, 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>`