Struct Subscriptions

pub(super) struct Subscriptions {
    subs: Mutex<HashMap<SubscriptionID, Arc<Subscription>>>,
    sub_buffer_size: usize,
}

Manages subscriptions for the client.

Fields

subs: Mutex<HashMap<SubscriptionID, Arc<Subscription>>>

sub_buffer_size: usize

Implementations

impl Subscriptions

pub(super) fn new(sub_buffer_size: usize) -> Arc<Self>

Creates a new Subscriptions.

pub(super) async fn subscribe(&self, id: SubscriptionID) -> Arc<Subscription>

Returns a new Subscription

pub(super) async fn clear(&self)

Closes subscription channels and clear the inner map.

pub(super) async fn unsubscribe(&self, id: &SubscriptionID)

Unsubscribe from the provided subscription id.

pub(super) async fn notify(&self, nt: Notification) -> Result<()>

Notifies the subscription about the given notification.