Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

订阅状态管理器

负责管理资源订阅的本地状态，提供线程安全的订阅管理接口。

Implementations

impl SubscriptionManager

pub fn new() -> Self

创建新的订阅管理器

pub async fn add_subscription(&self, uri: String) -> Result<bool, String>

添加订阅

参数

• uri: 资源 URI

返回

• Ok(true): 新增订阅
• Ok(false): 已存在，无需重复订阅

pub async fn remove_subscription(&self, uri: &str) -> Result<bool, String>

移除订阅

参数

• uri: 资源 URI

返回

• Ok(true): 找到并移除
• Ok(false): 未找到

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

检查是否已订阅

参数

• uri: 资源 URI

返回

• true: 已订阅
• false: 未订阅

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

获取所有订阅的 URI 列表

返回

• 所有订阅 URI 的向量

pub async fn subscription_count(&self) -> usize

获取订阅数量

返回

• 当前订阅总数

pub async fn clear(&self)

清空所有订阅

pub async fn add_subscriptions_batch(&self, uris: Vec<String>) -> usize

批量添加订阅

参数

• uris: 资源 URI 列表

返回

• 成功添加的数量

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 Debug for SubscriptionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.