Struct TopicRouter 

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

Routes messages of type T to subscribed handlers based on topic patterns.

Supports wildcard patterns (* and ?) and priority-based ordering. Caches topic-to-subscription mappings for efficient repeated lookups.

Implementations

impl<T: 'static> TopicRouter<T>

pub fn new() -> Self

Creates a new empty topic router.

pub fn subscription_count(&self) -> usize

Returns the number of active subscriptions.

pub fn is_empty(&self) -> bool

Returns whether there are any subscriptions.

pub fn patterns(&self) -> Vec<&str>

Returns all active subscription patterns.

pub fn handler_ids(&self) -> Vec<&str>

Returns all subscription handler IDs.

pub fn subscribe( &mut self, pattern: MStr<Pattern>, handler: TypedHandler<T>, priority: u32, )

Subscribes a handler to a topic pattern.

Warning

Assigning priority is an advanced feature. Higher priority handlers receive messages before lower priority handlers.

pub fn unsubscribe(&mut self, pattern: MStr<Pattern>, handler: &TypedHandler<T>)

Unsubscribes a handler from a topic pattern.

pub fn remove_handler(&mut self, pattern: MStr<Pattern>, handler_id: Ustr)

Removes a specific handler from a pattern by handler ID.

pub fn is_subscribed( &self, pattern: MStr<Pattern>, handler: &TypedHandler<T>, ) -> bool

Checks if a handler is subscribed to a pattern.

pub fn has_subscribers(&self, topic: MStr<Topic>) -> bool

Returns whether there are subscribers for the topic.

pub fn subscriber_count(&self, topic: MStr<Topic>) -> usize

Returns the count of subscribers for a topic.

pub fn exact_subscriber_count(&self, topic: MStr<Topic>) -> usize

Returns the count of subscribers with an exact topic match, excluding wildcard pattern subscriptions.

pub fn publish(&mut self, topic: MStr<Topic>, message: &T)

Publishes a message to all handlers subscribed to matching patterns.

pub fn get_matching_handlers( &mut self, topic: MStr<Topic>, ) -> Vec<TypedHandler<T>>

Returns cloned handlers matching a topic for safe out-of-borrow calling.

Use this when handlers may need to access the message bus during execution. Note: Allocates a Vec on each call. For hot paths, prefer the thread-local buffer pattern used by publish_* functions.

pub fn clear(&mut self)

Clears all subscriptions and cache.

Trait Implementations

impl<T: Debug + 'static> Debug for TopicRouter<T>

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

Formats the value using the given formatter.

impl<T: 'static> Default for TopicRouter<T>

fn default() -> Self

Returns the “default value” for a type.