Struct SubscriptionBroker 

pub struct SubscriptionBroker { /* private fields */ }

订阅代理

基于内存 pub/sub 模式实现的事件分发

Implementations

impl SubscriptionBroker

pub fn new() -> Self

pub fn subscribe(&self, topic: &str) -> SubscriptionHandle

订阅主题

返回订阅句柄，drop 时自动取消订阅

pub fn publish(&self, topic: &str, payload: Value) -> usize

发布事件到指定主题

返回实际投递到的订阅者数量

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

获取指定主题的订阅者数量

pub fn topic_count(&self) -> usize

获取活跃主题数量

Trait Implementations

impl Clone for SubscriptionBroker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SubscriptionBroker

fn default() -> Self

Returns the “default value” for a type.