Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Subscription manager

Implementations

impl SubscriptionManager

pub fn new() -> Self

Creates a new SubscriptionManager

pub async fn add_subscription( &self, stream: String, symbol: String, sub_type: SubscriptionType, sender: UnboundedSender<Value>, ) -> Result<()>

Adds a subscription to the manager

pub async fn remove_subscription(&self, stream: &str) -> Result<()>

Removes a subscription by stream name

pub async fn get_subscription(&self, stream: &str) -> Option<Subscription>

Retrieves a subscription by stream name

pub async fn has_subscription(&self, stream: &str) -> bool

Checks whether a subscription exists for the given stream

pub async fn get_all_subscriptions(&self) -> Vec<Subscription>

Returns all registered subscriptions

pub async fn get_subscriptions_by_symbol( &self, symbol: &str, ) -> Vec<Subscription>

Returns all subscriptions associated with a symbol

pub fn active_count(&self) -> usize

Returns the number of active subscriptions

pub async fn clear(&self)

Removes all subscriptions and clears indexes

pub async fn send_to_stream(&self, stream: &str, message: Value) -> bool

Sends a message to subscribers of a specific stream

pub async fn send_to_symbol(&self, symbol: &str, message: &Value) -> usize

Sends a message to all subscribers of a symbol

Trait Implementations

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.