Struct TopicRouter

pub struct TopicRouter<T> { /* private fields */ }

Implementations

impl<T> TopicRouter<T>

pub fn new() -> TopicRouter<T>

pub fn add_subscription( &mut self, topic: TopicPatternPath, qos: QoS, subscription: T, ) -> (bool, SubscriptionId)

pub fn unsubscribe( &mut self, id: &SubscriptionId, ) -> Result<(bool, TopicPatternPath), TopicRouterError>

pub fn get_subscribers<'a>( &'a self, topic: &TopicPath, ) -> Vec<(&'a SubscriptionId, &'a (TopicPatternPath, QoS), &'a T)>

pub fn get_active_subscriptions( &self, ) -> impl Iterator<Item = &(TopicPatternPath, QoS)>

pub fn get_topics_for_unsubscribe(&self) -> HashSet<ArcStr>

Get all unique active topic patterns

pub fn get_topics_for_resubscribe(&self) -> HashMap<ArcStr, QoS>

Get all active topic patterns with their maximum QoS Returns unique topics (grouped by pattern) with the highest QoS among all subscribers

pub fn cleanup(&mut self)

Cleanup all internal data structures and close subscriber channels This method is called during shutdown to ensure proper resource cleanup

pub fn get_topic_by_id( &self, id: &SubscriptionId, ) -> Result<&(TopicPatternPath, QoS), TopicRouterError>

Trait Implementations

impl<T> Default for TopicRouter<T>

fn default() -> TopicRouter<T>

Returns the “default value” for a type.