Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Subscription manager

Manages the lifecycle of all WebSocket subscriptions, including:

• Adding and removing subscriptions
• Querying and validating subscriptions
• Tracking the number of active subscriptions

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

Arguments

• stream - Stream identifier (e.g. “btcusdt@ticker”)
• symbol - Normalized trading symbol (e.g. “BTCUSDT”)
• sub_type - Subscription classification
• sender - Channel for dispatching messages

Returns

Result of the insertion

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

Removes a subscription by stream name

Arguments

• stream - Stream identifier to remove

Returns

Result of the removal

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

Retrieves a subscription by stream name

Arguments

• stream - Stream identifier

Returns

Optional subscription record

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

Checks whether a subscription exists for the given stream

Arguments

• stream - Stream identifier

Returns

true if the subscription exists, otherwise false

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

Arguments

• symbol - Trading 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

Arguments

• stream - Stream identifier
• message - WebSocket payload to broadcast

Returns

true when the message was delivered, otherwise false

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

Sends a message to all subscribers of a symbol

Arguments

• symbol - Trading symbol
• message - Shared WebSocket payload

Returns

Number of subscribers that received the message

Trait Implementations

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.