relay filter/appview bootstrap
gmstn.systems
1use tokio::sync::broadcast;
2
3#[derive(Clone)]
4pub struct Broadcaster {
5 tx: broadcast::Sender<String>,
6}
7
8impl Broadcaster {
9 pub fn new(tx: broadcast::Sender<String>) -> Self {
10 Self { tx }
11 }
12
13 pub fn subscribe(&self) -> broadcast::Receiver<String> {
14 self.tx.subscribe()
15 }
16
17 #[allow(dead_code)]
18 pub fn send(&self, msg: String) -> Result<usize, broadcast::error::SendError<String>> {
19 self.tx.send(msg)
20 }
21}