Struct Channel

pub struct Channel {
    chan: Sender<NewNotification>,
    subs: Mutex<Vec<SubscriptionID>>,
}

Represents a connection channel for creating/removing subscriptions

Fields

chan: Sender<NewNotification>

subs: Mutex<Vec<SubscriptionID>>

Implementations

impl Channel

pub(crate) fn new(chan: Sender<NewNotification>) -> Arc<Channel>

Creates a new Channel

pub async fn new_subscription(self: &Arc<Self>, method: &str) -> Subscription

Creates a new Subscription

pub async fn remove_subscription(&self, id: &SubscriptionID)

Removes a Subscription

pub(crate) fn close(&self)

Closes the Channel