///
/// Triggers new topic metadata is received.
///
/// At this point, we only need to ensure that topic with init status can be moved
/// to pending or error state
///
Triggers new topic metadata is received.
At this point, we only need to ensure that topic with init status can be moved
to pending or error state
Triggers new topic metadata is received . At this point we only need to ensure that topic with init status can be moved to pending or error state
fn add_topic_action_handler(&self, topic: TopicKV, actions: &mut TopicActions) {
        let name = topic.key();
        debug!("AddTopic({}) - {}", name, topic);
        self.update_actions_next_state(&topic, actions);
    }
fn add_topic_action_handler ( & self , topic : TopicKV , actions : & mut TopicActions ) { let name = topic . key ( ) ; debug ! ( " " name topic ) ; self . update_actions_next_state ( & topic , actions ) ; }
Triggers new topic metadata is received.
Triggers new topic metadata is received .
&self
topic
TopicKV
actions
&mut TopicActions