Method unsubscribe

nodedb/src/control/pubsub.rs:323–330

Unsubscribe from a topic.

(&self, topic_name: &str, sub_id: u64)

    /// Unsubscribe from a topic.
    pub fn unsubscribe(&self, topic_name: &str, sub_id: u64) {
        let topics = super::lock_utils::read_or_recover(self.topics.read(), "topics");
        if let Some(topic_mutex) = topics.get(topic_name) {
            let mut topic = super::lock_utils::lock_or_recover(topic_mutex.lock(), "topic");
            topic.subscribers.remove(&sub_id);
            debug!(topic = topic_name, sub_id, "unsubscribed");
        }
    }

    /// Get topic stats.
    pub fn topic_stats(&self, topic_name: &str) -> Option<TopicStats> {