Struct Channel 

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

Represents a connection channel for creating/removing subscriptions

Fields

chan: Sender<NewNotification>

subs: Mutex<HashSet<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, sub_id: Option<SubscriptionID>, ) -> Result<Subscription>

Creates a new Subscription

pub async fn remove_subscription(&self, id: &SubscriptionID) -> Result<()>

Removes a Subscription

pub(crate) fn close(&self)

Closes the Channel