Method create_topic

nodedb/src/control/pubsub.rs:146–157

Create a new topic.

(&self, name: &str)

    /// Create a new topic.
    pub fn create_topic(&self, name: &str) -> Result<(), TopicError> {
        let mut topics = super::lock_utils::write_or_recover(self.topics.write(), "topics");
        if topics.contains_key(name) {
            return Err(TopicError::AlreadyExists(name.to_string()));
        }
        topics.insert(
            name.to_string(),
            Mutex::new(Topic::new(self.default_max_messages)),
        );
        debug!(topic = name, "topic created");
        Ok(())
    }

    /// Drop a topic and all its messages.
    pub fn drop_topic(&self, name: &str) -> Result<(), TopicError> {