Struct MultiChannelManager 

pub struct MultiChannelManager { /* private fields */ }

Multi-topic channel manager

Implementations

impl MultiChannelManager

pub fn new(default_config: ChannelConfig) -> Self

Create a new multi-channel manager

pub fn get_or_create(&self, topic: &str) -> Arc<TopicChannel>

Get or create a channel

pub async fn subscribe( &self, topic: &str, subscriber: ConnectionId, ) -> Result<()>

Subscribe to a topic

pub async fn unsubscribe( &self, topic: &str, subscriber: &ConnectionId, ) -> Result<()>

Unsubscribe from a topic

pub async fn publish(&self, topic: &str, message: Message) -> Result<usize>

Publish to a topic

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

Get all topics

pub fn channel_count(&self) -> usize

Get channel count

pub fn remove_channel(&self, topic: &str) -> Option<Arc<TopicChannel>>

Remove a channel

pub fn clear(&self)

Clear all channels