Struct BroadcastManager 

pub struct BroadcastManager { /* private fields */ }

Manages named broadcast channels.

Thread-safe via interior mutability (RwLock for channel map, atomics for counters).

Implementations

impl BroadcastManager

pub fn new(config: BroadcastConfig) -> Self

Create a new broadcast manager.

pub async fn publish( &self, channel: &str, event: String, payload: Value, ) -> Result<usize, BroadcastError>

Publish a message to a named channel.

Creates the channel if it doesn’t exist. Returns the number of receivers that were notified (0 if nobody is listening).

Errors

Returns error if the channel limit is exceeded or the payload is too large.

pub async fn subscribe( &self, channel: &str, ) -> Result<Receiver<BroadcastMessage>, BroadcastError>

Subscribe to a named channel. Creates the channel if it doesn’t exist.

Errors

Returns error if the channel limit is exceeded.

pub async fn gc_empty_channels(&self) -> usize

Remove channels with no active subscribers to prevent memory leaks.

pub async fn stats(&self) -> BroadcastStats

Get current broadcast statistics.

pub async fn channel_count(&self) -> usize

Get the number of active channels.

Trait Implementations

impl Debug for BroadcastManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.