Type Alias ImportNotifications

pub type ImportNotifications<Block> = TracingUnboundedReceiver<BlockImportNotification<Block>>;

Type that implements futures::Stream of block import events.

Aliased Type

struct ImportNotifications<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>