signal.rs

/// Sends cloned values to multiple monitoring `Receiver`s.
pub struct Signal<T> {
    txs: Vec<Sender<T>>,
}

impl<T: Send> Signal<T> {
    /// Create a signal with no monitors connected.
    pub fn new() -> Signal<T> {
        Signal { txs: Vec::new() }
    }

    /// Create a new `Receiver` to monitor signals.
    pub fn new_monitor(&mut self) -> Receiver<T> {
        let (tx, rx) = channel();
        self.txs.push(tx);
        rx
    }
}

impl<T: Clone + Send> Signal<T> {
    /// Sends a clone of signal `x` to each connected `Receiver`.
    pub fn send(&mut self, x: T) {
        let txs = mem::replace(&mut self.txs, Vec::new());
        // orphaned `Sender`s will be removed from `txs`
        self.txs = txs.move_iter().filter(|tx| {
            tx.send_opt(x.clone()).is_ok()
        }).collect();
    }
}