Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Subscription manager for real-time updates.

Implementations

impl SubscriptionManager

pub async fn new(config: ClientConfig) -> Result<Self>

Create a new subscription manager.

pub fn subscribe(&self) -> Receiver<SubscriptionEvent>

Subscribe to receive events.

pub async fn subscribe_address(&self, address: &str) -> Result<Option<String>>

Subscribe to address status changes.

Returns the current status hash (or None if no history).

pub async fn unsubscribe_address(&self, address: &str) -> Result<bool>

Unsubscribe from address status changes.

pub async fn subscribe_headers(&self) -> Result<BlockHeaderEvent>

Subscribe to new block headers.

Returns the current tip header.

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

Get all subscribed addresses.

pub async fn is_headers_subscribed(&self) -> bool

Check if headers subscription is active.

pub async fn subscription_count(&self) -> usize

Get subscription count.

pub async fn process_notification( &self, method: &str, params: &[Value], ) -> Result<()>

Process a notification from the server.

pub async fn stop(&self)

Stop the subscription manager.

pub async fn is_running(&self) -> bool

Check if the manager is running.