Method close

flow-rs/src/broker.rs:157–161

(&self)

    }

    pub fn close(&self) {
        self.running.store(false, Ordering::Release);
        self.notify.close();
        self.sub.close();
    }
}