soncai 0.0.1

simple signal system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::sync::{Arc, Weak};

use super::{Emitter, Receiver};

pub struct Signal<D> {
    receivers: Vec<Weak<Box<dyn Receiver<D>>>>,
}

impl<D> Signal<D> {
    pub fn new() -> Self {
        Signal {
            receivers: Vec::default(),
        }
    }
    pub fn push<R>(&mut self, receiver: R) where R: Receiver<D> + Send + 'static{
        self.receivers.push(Arc::downgrade(&Arc::new(Box::new(receiver))));
    }
}
impl<D> Emitter<D> for Signal<D> {
    fn emit(&self, data: &D) {
        for receiver in &self.receivers {
            if let Some(receiver) = receiver.upgrade() {
                receiver.receive(data);
            }
        }
    }
}