Struct Subscriber 

pub struct Subscriber {
    pub id: SubscriberId,
    pub subscriptions: Vec<Subscription>,
    pub created_at: u64,
    pub last_active: u64,
    pub events_received: u64,
    pub events_acknowledged: u64,
}

A subscriber that receives events.

Fields

id: SubscriberId

subscriptions: Vec<Subscription>

created_at: u64

last_active: u64

events_received: u64

events_acknowledged: u64

Implementations

impl Subscriber

pub fn new(id: impl Into<SubscriberId>) -> Self

Create a new subscriber.

pub fn add_subscription(&mut self, subscription: Subscription)

Add a subscription.

pub fn remove_subscription(&mut self, subscription_id: &SubscriberId)

Remove a subscription.

pub fn active_subscriptions(&self) -> Vec<&Subscription>

Get active subscriptions.

pub fn record_received(&mut self)

Record an event received.

pub fn record_acknowledged(&mut self)

Record an event acknowledged.

pub fn is_active(&self) -> bool

Check if the subscriber is active.

Trait Implementations

impl Clone for Subscriber

fn clone(&self) -> Subscriber

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Subscriber

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

Formats the value using the given formatter.