Struct CrossChainEventBus 

pub struct CrossChainEventBus { /* private fields */ }

Fan-out broadcast bus that aggregates events from all managed chains.

Multiple subscribers can each receive every event via tokio::sync::broadcast. If a subscriber falls behind and the buffer fills, lagged events are dropped for that subscriber (the channel returns broadcast::error::RecvError::Lagged).

Implementations

impl CrossChainEventBus

pub fn new(capacity: usize) -> Self

Create a new bus with the given channel capacity.

capacity is the maximum number of events buffered per subscriber before the oldest events are dropped. A value of 1024 is a reasonable default for most use cases.

pub fn push(&self, chain: &str, event: DecodedEvent) -> usize

Push an event from chain onto the bus.

Returns the number of active subscribers that received the event. If there are no subscribers, the event is silently discarded.

pub fn subscribe(&self) -> CrossChainReceiver

Subscribe to the event bus.

Each subscriber receives a clone of every event pushed after the subscription is created.

pub fn subscriber_count(&self) -> usize

Returns the number of active subscribers.

Trait Implementations

impl Clone for CrossChainEventBus

fn clone(&self) -> CrossChainEventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.