Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages resource subscriptions across all sessions.

Thread-safe and can be shared across handlers and background tasks.

Implementations

impl SubscriptionManager

pub fn new() -> Self

Create a new subscription manager.

pub async fn subscribe(&self, session_id: &SessionId, uri: &str) -> bool

Subscribe a session to a resource.

Returns true if this is a new subscription, false if already subscribed.

pub async fn unsubscribe(&self, session_id: &SessionId, uri: &str) -> bool

Unsubscribe a session from a resource.

Returns true if the subscription existed, false otherwise.

pub async fn unsubscribe_all(&self, session_id: &SessionId)

Unsubscribe a session from all resources.

Call this when a session disconnects.

pub async fn subscribers(&self, uri: &str) -> Vec<SessionId>

Get all session IDs subscribed to a resource.

pub async fn subscriptions(&self, session_id: &SessionId) -> Vec<String>

Get all resources a session is subscribed to.

pub async fn is_subscribed(&self, session_id: &SessionId, uri: &str) -> bool

Check if a session is subscribed to a resource.

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

Get the number of subscribers for a resource.

pub async fn total_subscriptions(&self) -> usize

Get total number of active subscriptions.

Trait Implementations

impl Clone for SubscriptionManager

fn clone(&self) -> SubscriptionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SubscriptionManager

fn default() -> SubscriptionManager

Returns the “default value” for a type.