[−][src]Trait futures::stream::FusedStream
A stream 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<S> FusedStream for Box<S> where
S: FusedStream + Unpin + ?Sized,
[src]
S: FusedStream + Unpin + ?Sized,
fn is_terminated(&self) -> bool
[src]
impl<P> FusedStream for Pin<P> where
P: DerefMut + Unpin,
<P as Deref>::Target: FusedStream,
[src]
P: DerefMut + Unpin,
<P as Deref>::Target: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<'_, F> FusedStream for &'_ mut F where
F: FusedStream + Unpin + ?Sized,
[src]
F: FusedStream + Unpin + ?Sized,
fn is_terminated(&self) -> bool
[src]
Implementors
impl<A, B> FusedStream for Either<A, B> where
A: FusedStream,
B: FusedStream<Item = <A as Stream>::Item>,
[src]
A: FusedStream,
B: FusedStream<Item = <A as Stream>::Item>,
fn is_terminated(&self) -> bool
[src]
impl<Fut> FusedStream for FlattenStream<Fut> where
Fut: Future,
<Fut as Future>::Output: Stream,
<Fut as Future>::Output: FusedStream,
[src]
Fut: Future,
<Fut as Future>::Output: Stream,
<Fut as Future>::Output: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<Fut> FusedStream for futures::future::IntoStream<Fut> where
Fut: Future,
[src]
Fut: Future,
fn is_terminated(&self) -> bool
[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]
Fut: TryFuture,
<Fut as TryFuture>::Ok: TryStream,
<Fut as TryFuture>::Ok: FusedStream,
<<Fut as TryFuture>::Ok as TryStream>::Error == <Fut as TryFuture>::Error,
fn is_terminated(&self) -> bool
[src]
impl<Fut> FusedStream for FuturesUnordered<Fut> where
Fut: Future,
[src]
Fut: Future,
fn is_terminated(&self) -> bool
[src]
impl<Fut> FusedStream for Once<Fut> where
Fut: Future,
[src]
Fut: Future,
fn is_terminated(&self) -> bool
[src]
impl<Fut, S> FusedStream for FlattenSink<Fut, S> where
Fut: TryFuture<Ok = S>,
S: TryStream<Error = <Fut as TryFuture>::Error> + FusedStream,
[src]
Fut: TryFuture<Ok = S>,
S: TryStream<Error = <Fut as TryFuture>::Error> + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<S> FusedStream for Fuse<S> where
S: Stream,
[src]
S: Stream,
fn is_terminated(&self) -> bool
[src]
impl<S, F> FusedStream for SinkMapErr<S, F> where
S: FusedStream,
[src]
S: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<S, Item> FusedStream for Buffer<S, Item> where
S: Sink<Item> + FusedStream,
[src]
S: Sink<Item> + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<S, Item, E> FusedStream for SinkErrInto<S, Item, E> where
S: Sink<Item> + FusedStream,
<S as Sink<Item>>::Error: Into<E>,
[src]
S: Sink<Item> + FusedStream,
<S as Sink<Item>>::Error: Into<E>,
fn is_terminated(&self) -> bool
[src]
impl<S, Item, U, St, F> FusedStream for WithFlatMap<S, Item, U, St, F> where
F: FnMut(U) -> St,
S: FusedStream + Sink<Item>,
St: Stream<Item = Result<Item, <S as Sink<Item>>::Error>>,
[src]
F: FnMut(U) -> St,
S: FusedStream + Sink<Item>,
St: Stream<Item = Result<Item, <S as Sink<Item>>::Error>>,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for BufferUnordered<St> where
St: Stream,
<St as Stream>::Item: Future,
[src]
St: Stream,
<St as Stream>::Item: Future,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for CatchUnwind<St> where
St: UnwindSafe + FusedStream,
[src]
St: UnwindSafe + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Chunks<St> where
St: FusedStream,
[src]
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Enumerate<St> where
St: Stream + FusedStream,
[src]
St: Stream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Flatten<St> where
St: FusedStream,
<St as Stream>::Item: Stream,
[src]
St: FusedStream,
<St as Stream>::Item: Stream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for futures::stream::IntoStream<St> where
St: FusedStream + TryStream,
[src]
St: FusedStream + TryStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Peekable<St> where
St: Stream,
[src]
St: Stream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for SelectAll<St> where
St: Unpin + Stream,
[src]
St: Unpin + Stream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Skip<St> where
St: FusedStream,
[src]
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for Take<St> where
St: FusedStream,
[src]
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St> FusedStream for TryFlatten<St> where
St: TryStream + FusedStream,
<St as TryStream>::Ok: TryStream,
<<St as TryStream>::Ok as TryStream>::Error: From<<St as TryStream>::Error>,
[src]
St: TryStream + FusedStream,
<St as TryStream>::Ok: TryStream,
<<St as TryStream>::Ok as TryStream>::Error: From<<St as TryStream>::Error>,
fn is_terminated(&self) -> bool
[src]
impl<St, E> FusedStream for ErrInto<St, E> where
St: TryStream + FusedStream,
<St as TryStream>::Error: Into<E>,
[src]
St: TryStream + FusedStream,
<St as TryStream>::Error: Into<E>,
fn is_terminated(&self) -> bool
[src]
impl<St, F> FusedStream for Inspect<St, F> where
F: FnMut(&<St as Stream>::Item),
St: FusedStream,
[src]
F: FnMut(&<St as Stream>::Item),
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, F> FusedStream for InspectErr<St, F> where
F: FnMut(&<St as TryStream>::Error),
St: TryStream + FusedStream,
[src]
F: FnMut(&<St as TryStream>::Error),
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, F> FusedStream for InspectOk<St, F> where
F: FnMut(&<St as TryStream>::Ok),
St: TryStream + FusedStream,
[src]
F: FnMut(&<St as TryStream>::Ok),
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, F, E> FusedStream for MapErr<St, F> where
F: FnMut(<St as TryStream>::Error) -> E,
St: TryStream + FusedStream,
[src]
F: FnMut(<St as TryStream>::Error) -> E,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, F, T> FusedStream for Map<St, F> where
F: FnMut(<St as Stream>::Item) -> T,
St: FusedStream,
[src]
F: FnMut(<St as Stream>::Item) -> T,
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, F, T> FusedStream for MapOk<St, F> where
F: FnMut(<St as TryStream>::Ok) -> T,
St: TryStream + FusedStream,
[src]
F: FnMut(<St as TryStream>::Ok) -> T,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for AndThen<St, Fut, F> where
F: FnMut(<St as TryStream>::Ok) -> Fut,
Fut: TryFuture<Error = <St as TryStream>::Error>,
St: TryStream + FusedStream,
[src]
F: FnMut(<St as TryStream>::Ok) -> Fut,
Fut: TryFuture<Error = <St as TryStream>::Error>,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[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]
F: FnMut(&<St as Stream>::Item) -> Fut,
Fut: Future<Output = bool>,
St: Stream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for OrElse<St, Fut, F> where
F: FnMut(<St as TryStream>::Error) -> Fut,
Fut: TryFuture<Ok = <St as TryStream>::Ok>,
St: TryStream + FusedStream,
[src]
F: FnMut(<St as TryStream>::Error) -> Fut,
Fut: TryFuture<Ok = <St as TryStream>::Ok>,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for SkipWhile<St, Fut, F> where
F: FnMut(&<St as Stream>::Item) -> Fut,
Fut: Future<Output = bool>,
St: FusedStream,
[src]
F: FnMut(&<St as Stream>::Item) -> Fut,
Fut: Future<Output = bool>,
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> where
F: FnMut(&<St as Stream>::Item) -> Fut,
Fut: Future<Output = bool>,
St: FusedStream,
[src]
F: FnMut(&<St as Stream>::Item) -> Fut,
Fut: Future<Output = bool>,
St: FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for Then<St, Fut, F> where
F: FnMut(<St as Stream>::Item) -> Fut,
Fut: Future,
St: FusedStream,
[src]
F: FnMut(<St as Stream>::Item) -> Fut,
Fut: Future,
St: FusedStream,
fn is_terminated(&self) -> bool
[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]
F: FnMut(&<St as TryStream>::Ok) -> Fut,
Fut: Future<Output = bool>,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St, Fut, F> FusedStream for TrySkipWhile<St, Fut, F> where
F: FnMut(&<St as TryStream>::Ok) -> Fut,
Fut: TryFuture<Ok = bool, Error = <St as TryStream>::Error>,
St: TryStream + FusedStream,
[src]
F: FnMut(&<St as TryStream>::Ok) -> Fut,
Fut: TryFuture<Ok = bool, Error = <St as TryStream>::Error>,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[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]
F: FnMut(<St as Stream>::Item) -> Fut,
Fut: Future<Output = Option<T>>,
St: Stream + FusedStream,
fn is_terminated(&self) -> bool
[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]
F: FnMut(<St as TryStream>::Ok) -> Fut,
Fut: TryFuture<Ok = Option<T>, Error = <St as TryStream>::Error>,
St: TryStream + FusedStream,
fn is_terminated(&self) -> bool
[src]
impl<St1, St2> FusedStream for Chain<St1, St2> where
St1: Stream,
St2: FusedStream<Item = <St1 as Stream>::Item>,
[src]
St1: Stream,
St2: FusedStream<Item = <St1 as Stream>::Item>,
fn is_terminated(&self) -> bool
[src]
impl<St1, St2> FusedStream for Select<St1, St2> where
St1: Stream,
St2: Stream<Item = <St1 as Stream>::Item>,
[src]
St1: Stream,
St2: Stream<Item = <St1 as Stream>::Item>,
fn is_terminated(&self) -> bool
[src]
impl<St1, St2> FusedStream for Zip<St1, St2> where
St1: Stream,
St2: Stream,
[src]
St1: Stream,
St2: Stream,
fn is_terminated(&self) -> bool
[src]
impl<T> FusedStream for Receiver<T>
[src]
fn is_terminated(&self) -> bool
[src]
impl<T> FusedStream for UnboundedReceiver<T>
[src]
fn is_terminated(&self) -> bool
[src]
impl<T> FusedStream for Empty<T>
[src]
fn is_terminated(&self) -> bool
[src]
impl<T> FusedStream for Pending<T>
[src]
fn is_terminated(&self) -> bool
[src]
impl<T> FusedStream for Repeat<T> where
T: Clone,
[src]
T: Clone,
fn is_terminated(&self) -> bool
[src]
impl<T, F, Fut, Item> FusedStream for Unfold<T, F, Fut> where
F: FnMut(T) -> Fut,
Fut: Future<Output = Option<(Item, T)>>,
[src]
F: FnMut(T) -> Fut,
Fut: Future<Output = Option<(Item, T)>>,