Struct BusManager 

pub struct BusManager { /* private fields */ }

Implementations

impl BusManager

pub fn new() -> BusManager

pub fn with_capacity(capacity: usize) -> BusManager

pub async fn get_or_create_state_bus( &self, view_id: &str, key: &str, ) -> Receiver<Arc<Bytes>>

Get or create a state bus (latest-value semantics) Each (view_id, key) pair gets its own watch channel

pub async fn get_or_create_list_bus( &self, view_id: &str, ) -> Receiver<Arc<BusMessage>>

pub async fn publish_state(&self, view_id: &str, key: &str, frame: Arc<Bytes>)

Publish to a state bus (latest-value)

pub async fn publish_list(&self, view_id: &str, message: Arc<BusMessage>)

pub async fn cleanup_stale_state_buses(&self) -> usize

pub async fn cleanup_stale_list_buses(&self) -> usize

pub async fn bus_counts(&self) -> (usize, usize)

Trait Implementations

impl Clone for BusManager

fn clone(&self) -> BusManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for BusManager

fn default() -> BusManager

Returns the “default value” for a type.