Struct CardEventBus 

pub struct CardEventBus { /* private fields */ }

Process-wide fan-out bus. Subscribers are registered once at startup (from ALC_CARD_SINKS) and stored behind a Mutex so that tests can swap them out via replace_subscribers_for_test without losing the singleton identity.

Implementations

impl CardEventBus

pub fn new(subscribers: Vec<Arc<dyn CardSubscriber>>) -> Self

Build a bus from an explicit subscriber list. Used both by the env loader and by install_event_bus_for_test.

pub fn stats(&self) -> &Arc<SubscriberStats>

Shared handle to the per-subscriber counters.

pub fn publish(&self, ev: &CardEvent)

Fan out ev to every registered subscriber serially. Subscriber failures are counted in SubscriberStats and logged but do not propagate.

pub fn publish_to(&self, target: &str, ev: &CardEvent) -> Result<(), String>

Deliver ev to exactly one subscriber identified by target URI. Returns Err when no subscriber matches or the subscriber itself fails (backfill path needs the caller to know).

pub fn subscriber_uris(&self) -> Vec<String>

List every subscriber URI currently registered on the bus.

pub fn find_subscriber(&self, uri: &str) -> Option<Arc<dyn CardSubscriber>>

Look up a subscriber by URI (as returned by describe). Returns None when no subscriber matches. Used by alc_card_sink_backfill to dispatch has_card checks against a specific sink.