Struct SubscriptionManager

pub struct SubscriptionManager<S, Key = ()> {
    pub stream_code: u32,
    pub subscribes: HashMap<ConnectionId, SubscribeContext<S>>,
    pub mappings: HashMap<Key, HashSet<ConnectionId>>,
}

Fields

stream_code: u32

subscribes: HashMap<ConnectionId, SubscribeContext<S>>

mappings: HashMap<Key, HashSet<ConnectionId>>

Implementations

impl<S, Key: Eq + Hash> SubscriptionManager<S, Key>

pub fn new(stream_code: u32) -> Self

pub fn subscribe( &mut self, ctx: RequestContext, setting: S, modify: impl FnOnce(&mut SubscribeContext<S>), )

pub fn subscribe_with_keys( &mut self, ctx: RequestContext, keys: Vec<Key>, setting: S, modify: impl FnOnce(&mut SubscribeContext<S>), )

pub fn subscribe_with( &mut self, ctx: RequestContext, keys: Vec<Key>, new: impl FnOnce() -> S, modify: impl FnOnce(&mut SubscribeContext<S>), )

pub fn unsubscribe(&mut self, connection_id: ConnectionId)

pub fn unsubscribe_with( &mut self, connection_id: ConnectionId, remove: impl Fn(&mut SubscribeContext<S>) -> (bool, Vec<Key>), )

pub fn publish_to( &mut self, toolbox: &ArcToolbox, connection_id: ConnectionId, msg: &impl Serialize, )

pub fn publish_to_key<Q>( &mut self, toolbox: &ArcToolbox, key: &Q, msg: &impl Serialize, )

where Key: Borrow<Q>, Q: Eq + Hash + ?Sized,

pub fn publish_to_keys<Q>( &mut self, toolbox: &ArcToolbox, keys: &[&Q], msg: &impl Serialize, )

where Key: Borrow<Q>, Q: Eq + Hash + ?Sized,

pub fn publish_with_filter<M: Serialize>( &mut self, toolbox: &ArcToolbox, filter: impl Fn(&SubscribeContext<S>) -> Option<M>, )

pub fn publish_to_all(&mut self, toolbox: &ArcToolbox, msg: &impl Serialize)