pub struct SubscriptionManager { /* private fields */ }Expand description
Manages subscriptions to event groups
Implementations§
Source§impl SubscriptionManager
impl SubscriptionManager
Sourcepub fn subscribe(
&mut self,
service_id: u16,
instance_id: u16,
event_group_id: u16,
subscriber_addr: SocketAddrV4,
)
pub fn subscribe( &mut self, service_id: u16, instance_id: u16, event_group_id: u16, subscriber_addr: SocketAddrV4, )
Add a subscriber to an event group
Sourcepub fn unsubscribe(
&mut self,
service_id: u16,
instance_id: u16,
event_group_id: u16,
subscriber_addr: SocketAddrV4,
)
pub fn unsubscribe( &mut self, service_id: u16, instance_id: u16, event_group_id: u16, subscriber_addr: SocketAddrV4, )
Remove a subscriber from an event group
Sourcepub fn get_subscribers(
&self,
service_id: u16,
instance_id: u16,
event_group_id: u16,
) -> Vec<Subscriber>
pub fn get_subscribers( &self, service_id: u16, instance_id: u16, event_group_id: u16, ) -> Vec<Subscriber>
Get all subscribers for an event group
Sourcepub fn subscription_count(&self) -> usize
pub fn subscription_count(&self) -> usize
Get total number of active subscriptions
Trait Implementations§
Source§impl Debug for SubscriptionManager
impl Debug for SubscriptionManager
Auto Trait Implementations§
impl Freeze for SubscriptionManager
impl RefUnwindSafe for SubscriptionManager
impl Send for SubscriptionManager
impl Sync for SubscriptionManager
impl Unpin for SubscriptionManager
impl UnsafeUnpin for SubscriptionManager
impl UnwindSafe for SubscriptionManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more