Struct NotificationBus 

pub struct NotificationBus { /* private fields */ }

Message bus for distributing change notifications

Implementations

impl NotificationBus

pub fn new() -> Self

Create a new notification bus

pub fn subscribe(&self, filter: NotificationFilter) -> Subscription

Subscribe to notifications with a filter

pub fn subscribe_all(&self) -> Subscription

Subscribe to all notifications (convenience method)

pub fn subscribe_key(&self, key: &str) -> Subscription

Subscribe to notifications for a specific key

pub fn subscribe_prefix(&self, prefix: &str) -> Subscription

Subscribe to notifications for keys with a specific prefix

pub fn subscribe_change_type(&self, change_type: ChangeType) -> Subscription

Subscribe to notifications of a specific change type

pub fn unsubscribe(&self, subscription_id: SubscriptionId)

Unsubscribe from notifications

pub async fn publish(&self, notification: ChangeNotification)

Publish a notification to all subscribers

pub fn broadcast_receiver(&self) -> Receiver<ChangeNotification>

Get a broadcast receiver for all notifications

pub fn get_stats(&self) -> NotificationStats

Get current statistics

pub fn cleanup_closed_subscribers(&self)

Clean up closed subscriber channels

pub fn subscriber_count(&self) -> usize

Get the number of active subscribers

Trait Implementations

impl Default for NotificationBus

fn default() -> Self

Returns the “default value” for a type.