referrerpolicy=no-referrer-when-downgrade

Trait polkadot_node_subsystem::gen::futures::prelude::stream::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.

Implementations on Foreign Types§

source§

impl FusedStream for DelayedApprovalTimer

source§

fn is_terminated(&self) -> bool

source§

impl<Ch, R> FusedStream for Receiver<Ch, R>
where R: Unsubscribe,

source§

fn is_terminated(&self) -> bool

§

impl<F> FusedStream for &mut F
where F: FusedStream + Unpin + ?Sized,

§

fn is_terminated(&self) -> bool

§

impl<O> FusedStream for Boxed<O>

§

fn is_terminated(&self) -> bool

source§

impl<Payload> FusedStream for NotificationReceiver<Payload>

source§

fn is_terminated(&self) -> bool

§

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

§

fn is_terminated(&self) -> bool

source§

impl<T> FusedStream for TracingUnboundedReceiver<T>

source§

fn is_terminated(&self) -> bool

§

impl<T> FusedStream for Receiver<T>

§

fn is_terminated(&self) -> bool

§

impl<T> FusedStream for WebSocketStream<T>
where T: AsyncRead + AsyncWrite + Unpin,

§

fn is_terminated(&self) -> bool

§

impl<TBehaviour> FusedStream for Swarm<TBehaviour>
where TBehaviour: NetworkBehaviour,

The stream of swarm events never terminates, so we can implement fused for it.

§

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 polkadot_node_subsystem::gen::futures::prelude::future::IntoStream<F>
where Once<F>: FusedStream,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

impl<S, Item> FusedStream for Buffer<S, Item>
where S: Sink<Item> + 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, 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<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<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<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 polkadot_node_subsystem::gen::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<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> 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 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, 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, 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<T> FusedStream for MeteredReceiver<T>

§

impl<T> FusedStream for UnboundedMeteredReceiver<T>

§

impl<T> FusedStream for polkadot_node_subsystem::gen::futures::channel::mpsc::Receiver<T>

§

impl<T> FusedStream for UnboundedReceiver<T>

§

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