Trait futures_util::stream::FusedStream

pub trait FusedStream: Stream {
    fn is_terminated(&self) -> bool;
}

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<F> FusedStream for &mut Fwhere
    F: FusedStream + Unpin + ?Sized,

fn is_terminated(&self) -> bool

impl<S> FusedStream for Box<S, Global>where
    S: FusedStream + Unpin + ?Sized,

fn is_terminated(&self) -> bool

impl<P> FusedStream for Pin<P>where
    P: DerefMut + Unpin,
    <P as Deref>::Target: FusedStream,

fn is_terminated(&self) -> bool

Implementors

impl<A, B> FusedStream for Either<A, B>where
    A: FusedStream,
    B: FusedStream<Item = A::Item>,

impl<A, F: FnMut() -> A> FusedStream for RepeatWith<F>

impl<B, St, S, Fut, F> FusedStream for Scan<St, S, Fut, F>where
    St: FusedStream,
    F: FnMut(&mut S, St::Item) -> Fut,
    Fut: Future<Output = Option<B>>,

impl<F> FusedStream for FlattenStream<F>where
    Flatten<F, <F as Future>::Output>: FusedStream,
    F: Future,

impl<F> FusedStream for futures_util::future::IntoStream<F>where
    Once<F>: FusedStream,

impl<Fut> FusedStream for TryFlattenStream<Fut>where
    TryFlatten<Fut, Fut::Ok>: FusedStream,
    Fut: TryFuture,

impl<Fut: Future> FusedStream for FuturesOrdered<Fut>

impl<Fut: Future> FusedStream for FuturesUnordered<Fut>

impl<Fut: Future> FusedStream for Once<Fut>

impl<S: Stream> FusedStream for Fuse<S>

impl<S: Stream> FusedStream for PollImmediate<S>

impl<St1, St2> FusedStream for Chain<St1, St2>where
    St1: Stream,
    St2: FusedStream<Item = St1::Item>,

impl<St1, St2> FusedStream for Select<St1, St2>where
    St1: Stream,
    St2: Stream<Item = St1::Item>,

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

impl<St1, St2, Clos, State> FusedStream for SelectWithStrategy<St1, St2, Clos, State>where
    St1: Stream,
    St2: Stream<Item = St1::Item>,
    Clos: FnMut(&mut State) -> PollNext,

impl<St> FusedStream for BufferUnordered<St>where
    St: Stream,
    St::Item: Future,

impl<St> FusedStream for Buffered<St>where
    St: Stream,
    St::Item: Future,

impl<St> FusedStream for Cycle<St>where
    St: Clone + Stream,

impl<St> FusedStream for Flatten<St>where
    Flatten<St, St::Item>: FusedStream,
    St: Stream,

impl<St> FusedStream for Take<St>where
    St: FusedStream,

impl<St> FusedStream for TryFlatten<St>where
    St: TryStream + FusedStream,
    St::Ok: TryStream,
    <St::Ok as TryStream>::Error: From<St::Error>,

impl<St> FusedStream for TryFlattenUnordered<St>where
    FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: FusedStream,
    St: TryStream,
    St::Ok: TryStream + Unpin,
    <St::Ok as TryStream>::Error: From<St::Error>,

impl<St, E> FusedStream for ErrInto<St, E>where
    MapErr<St, IntoFn<E>>: FusedStream,

impl<St, F> FusedStream for Inspect<St, F>where
    Map<St, InspectFn<F>>: FusedStream,

impl<St, F> FusedStream for InspectErr<St, F>where
    Inspect<IntoStream<St>, InspectErrFn<F>>: FusedStream,

impl<St, F> FusedStream for InspectOk<St, F>where
    Inspect<IntoStream<St>, InspectOkFn<F>>: FusedStream,

impl<St, F> FusedStream for Map<St, F>where
    St: FusedStream,
    F: FnMut1<St::Item>,

impl<St, F> FusedStream for MapErr<St, F>where
    Map<IntoStream<St>, MapErrFn<F>>: FusedStream,

impl<St, F> FusedStream for MapOk<St, F>where
    Map<IntoStream<St>, MapOkFn<F>>: FusedStream,

impl<St, Fut> FusedStream for TakeUntil<St, Fut>where
    St: Stream,
    Fut: Future,

impl<St, Fut, F> FusedStream for AndThen<St, Fut, F>where
    St: TryStream + FusedStream,
    F: FnMut(St::Ok) -> Fut,
    Fut: TryFuture<Error = St::Error>,

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> FusedStream for OrElse<St, Fut, F>where
    St: TryStream + FusedStream,
    F: FnMut(St::Error) -> Fut,
    Fut: TryFuture<Ok = St::Ok>,

impl<St, Fut, F> FusedStream for SkipWhile<St, Fut, F>where
    St: FusedStream,
    F: FnMut(&St::Item) -> Fut,
    Fut: Future<Output = bool>,

impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F>where
    St: FusedStream,
    F: FnMut(&St::Item) -> Fut,
    Fut: Future<Output = bool>,

impl<St, Fut, F> FusedStream for Then<St, Fut, F>where
    St: FusedStream,
    F: FnMut(St::Item) -> Fut,
    Fut: Future,

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

impl<St, Fut, F> FusedStream for TryTakeWhile<St, Fut, F>where
    St: TryStream + FusedStream,
    F: FnMut(&St::Ok) -> Fut,
    Fut: TryFuture<Ok = bool, Error = St::Error>,

impl<St, Fut, F, T> FusedStream for FilterMap<St, Fut, F>where
    St: Stream + FusedStream,
    F: FnMut1<St::Item, Output = Fut>,
    Fut: Future<Output = Option<T>>,

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,

impl<St, U, F> FusedStream for FlatMap<St, U, F>where
    Flatten<Map<St, F>, U>: FusedStream,

impl<St, U, F> FusedStream for FlatMapUnordered<St, U, F>where
    FlattenUnordered<Map<St, F>>: FusedStream,
    St: Stream,
    U: Stream + Unpin,
    F: FnMut(St::Item) -> U,

impl<St: FusedStream + UnwindSafe> FusedStream for CatchUnwind<St>

impl<St: FusedStream> FusedStream for Chunks<St>

impl<St: FusedStream> FusedStream for Skip<St>

impl<St: Stream + Unpin> FusedStream for SelectAll<St>

impl<St: Stream + FusedStream> FusedStream for Enumerate<St>

impl<St: Stream> FusedStream for Peekable<St>

impl<St: Stream> FusedStream for ReadyChunks<St>

impl<St: TryStream + FusedStream> FusedStream for futures_util::stream::IntoStream<St>

impl<St: TryStream + FusedStream> FusedStream for TryChunks<St>

impl<T> FusedStream for Empty<T>

impl<T> FusedStream for Pending<T>

impl<T> FusedStream for Repeat<T>where
    T: Clone,

impl<T, F, Fut, Item> FusedStream for Unfold<T, F, Fut>where
    F: FnMut(T) -> Fut,
    Fut: Future<Output = Option<(Item, T)>>,