Struct PubSubManager 

pub struct PubSubManager { /* private fields */ }

Topic-based publish/subscribe manager.

Thread-safe manager for real-time subscriptions. Supports topic-based subscriptions, automatic channel creation, and broadcast to all subscribers.

Implementations

impl PubSubManager

pub fn new(capacity: usize) -> Self

Create a new PubSubManager with specified channel capacity.

pub fn with_default_capacity() -> Self

Create a new PubSubManager with default capacity (256).

pub async fn subscribe(&self, topic: &str) -> Receiver<SubscriptionMessage>

Subscribe to a topic. Returns a receiver for messages.

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

Publish a message to a topic. Returns number of recipients.

pub async fn notify_update(&self, table: &str, id: &str, data: &Value)

Notify subscribers of a record update (publishes to record and table topics). Short-circuits with zero allocation if no subscribers exist.

pub async fn notify_delete(&self, table: &str, id: &str)

Notify subscribers of a record deletion. Short-circuits with zero allocation if no subscribers exist.

pub async fn notify_publish(&self, topic: &str, data: Value)

Notify subscribers of a custom published message. Short-circuits if no subscribers exist for this topic.

pub async fn topic_count(&self) -> usize

Get the number of active topics.

pub fn has_topics(&self) -> bool

Whether any subscription topic is live. Cheap (DashMap::is_empty), sync — callers on a write hot path gate record decode/notify behind this so a write with no subscribers pays a single atomic-load check.

pub async fn subscriber_count(&self, topic: &str) -> usize

Get the number of subscribers for a topic.

pub async fn has_topic(&self, topic: &str) -> bool

Check if a topic exists.

pub async fn remove_topic(&self, topic: &str) -> bool

Remove a topic. Returns true if it existed.

pub async fn cleanup_empty_topics(&self) -> usize

Remove topics with zero active subscribers.

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

List all active topic names.

Trait Implementations

impl Clone for PubSubManager

fn clone(&self) -> PubSubManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PubSubManager

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

Formats the value using the given formatter.

impl Default for PubSubManager

fn default() -> Self

Returns the “default value” for a type.