Struct ChainEventBus 

pub struct ChainEventBus { /* private fields */ }

A broadcast-based event bus for chain state changes.

Multiple subscribers can listen for events without blocking the publisher. The bus is cheap to clone (it shares the underlying channel via Arc).

Implementations

impl ChainEventBus

pub fn new() -> Self

Create a new event bus with the default capacity.

pub fn with_capacity(capacity: usize) -> Self

Create a new event bus with a custom capacity.

pub fn subscribe(&self) -> Receiver<ChainEvent>

Subscribe to chain events.

Returns a broadcast::Receiver that will receive all events emitted after this call. If the receiver falls behind, it will get a RecvError::Lagged with the number of missed events.

pub fn emit(&self, event: ChainEvent) -> usize

Emit a chain event to all subscribers.

Returns the number of active subscribers that received the event. Returns 0 if there are no subscribers (this is not an error).

pub fn subscriber_count(&self) -> usize

Get the current number of active subscribers.

pub fn notify_block_connected( &self, hash: BlockHash, height: u32, num_txs: usize, ) -> usize

Convenience: emit a BlockConnected event.

pub fn notify_block_disconnected(&self, hash: BlockHash, height: u32) -> usize

Convenience: emit a BlockDisconnected event.

pub fn notify_tx_added(&self, txid: Txid, vsize: u64, fee: i64) -> usize

Convenience: emit a TransactionAddedToMempool event.

pub fn notify_tx_removed( &self, txid: Txid, reason: MempoolRemovalReason, ) -> usize

Convenience: emit a TransactionRemovedFromMempool event.

Trait Implementations

impl Clone for ChainEventBus

fn clone(&self) -> ChainEventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ChainEventBus

fn default() -> Self

Returns the “default value” for a type.