Method topic

flow-rs/src/broker.rs:149–151

(&self)

    }

    pub fn topic(&self) -> &str {
        self.topic.as_str()
    }

    pub fn is_closed(&self) -> bool {
        self.running.load(Ordering::Relaxed)