Struct BlockTx 

pub struct BlockTx(/* private fields */);

Wrapper around watch::Sender to notify of new blocks.

This is used by essential-builder to notify essential-relayer and by essential-relayer to notify [validation] stream.

Implementations

impl BlockTx

pub fn new() -> Self

Create a new BlockTx to notify listeners of new blocks.

pub fn notify(&self)

Notify listeners that a new block has been received.

Note this is best effort and will still send even if there are currently no listeners.

pub fn new_listener(&self) -> BlockRx

Create a new BlockRx to listen for new blocks.

pub fn receiver_count(&self) -> usize

Get the number of receivers listening for new blocks.

Trait Implementations

impl Clone for BlockTx

fn clone(&self) -> BlockTx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for BlockTx

fn default() -> BlockTx

Returns the “default value” for a type.