Type Alias FinalityNotifications

pub type FinalityNotifications<Block> = TracingUnboundedReceiver<FinalityNotification<Block>>;

A stream of block finality notifications.

Aliased Type

struct FinalityNotifications<Block> { /* private fields */ }

Implementations

impl<T> TracingUnboundedReceiver<T>

pub fn close(&mut self) -> bool

Proxy function to [async_channel::Receiver].

pub fn try_recv(&mut self) -> Result<T, TryRecvError>

Proxy function to [async_channel::Receiver] that discounts the messages taken out.

pub fn len(&self) -> usize

The number of elements in the channel (proxy function to [async_channel::Receiver]).

pub fn name(&self) -> &'static str

The name of this receiver

Trait Implementations

impl<T> Debug for TracingUnboundedReceiver<T>

where T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T> Drop for TracingUnboundedReceiver<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> FusedStream for TracingUnboundedReceiver<T>

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl<T> Stream for TracingUnboundedReceiver<T>

type Item = T

Values yielded by the stream.

fn poll_next( self: Pin<&mut TracingUnboundedReceiver<T>>, cx: &mut Context<'_>, ) -> Poll<Option<T>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<T> Unpin for TracingUnboundedReceiver<T>