Skip to main content

FusedStream

Trait FusedStream 

pub trait FusedStream: Stream {
    // Required method
    fn is_terminated(&self) -> bool;
}
Expand description

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types§

§

impl<'a, T> FusedStream for RecvStream<'a, T>

§

fn is_terminated(&self) -> bool

§

impl<F> FusedStream for &mut F
where F: 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 as Stream>::Item>,

§

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

§

impl<B, St, S, Fut, F> FusedStream for Scan<St, S, Fut, F>
where St: FusedStream, F: FnMut(&mut S, <St as Stream>::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 rama::futures::prelude::future::IntoStream<F>
where Once<F>: FusedStream,

§

impl<Fut, Si> FusedStream for FlattenSink<Fut, Si>
where TryFlatten<Fut, Si>: FusedStream,

§

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

§

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

§

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

§

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

§

impl<S, F> FusedStream for SinkMapErr<S, F>
where S: FusedStream,

§

impl<S, Item, E> FusedStream for SinkErrInto<S, Item, E>
where S: Sink<Item> + FusedStream, <S as Sink<Item>>::Error: Into<E>,

§

impl<S, Item, U, Fut, F> FusedStream for With<S, Item, U, Fut, F>
where S: FusedStream + Sink<Item>, F: FnMut(U) -> Fut, Fut: Future,

§

impl<S, Item, U, St, F> FusedStream for WithFlatMap<S, Item, U, St, F>
where S: FusedStream + Sink<Item>, F: FnMut(U) -> St, St: Stream<Item = Result<Item, <S as Sink<Item>>::Error>>,

§

impl<S, Item> FusedStream for Buffer<S, Item>
where S: Sink<Item> + FusedStream,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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 as Stream>::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, F, T> FusedStream for FilterMap<St, Fut, F>
where St: Stream + FusedStream, F: FnMut1<<St as Stream>::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 as TryStream>::Error>, F: FnMut(<St as TryStream>::Ok) -> Fut,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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 FlattenUnorderedWithFlowController<Map<St, F>, ()>: FusedStream, St: Stream, U: Stream + Unpin, F: FnMut(<St as Stream>::Item) -> U,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

impl<St> FusedStream for rama::futures::prelude::stream::IntoStream<St>
where St: TryStream + FusedStream,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

impl<St> FusedStream for TryReadyChunks<St>
where St: TryStream + FusedStream,

§

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

§

impl<T> FusedStream for AsyncWebSocket<T>
where T: Io + Unpin,

§

impl<T> FusedStream for Empty<T>

§

impl<T> FusedStream for Pending<T>

§

impl<T> FusedStream for Receiver<T>

§

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

§

impl<T> FusedStream for UnboundedReceiver<T>