use tokio::sync::broadcast;

#[derive(Clone)]
pub struct Broadcaster {
    tx: broadcast::Sender<String>,
}

impl Broadcaster {
    pub fn new(tx: broadcast::Sender<String>) -> Self {
        Self { tx }
    }

    pub fn subscribe(&self) -> broadcast::Receiver<String> {
        self.tx.subscribe()
    }

    #[allow(dead_code)]
    pub fn send(&self, msg: String) -> Result<usize, broadcast::error::SendError<String>> {
        self.tx.send(msg)
    }
}