employees 0.1.0

A small runtime that hides all the boilerplate when using threads.
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use crossbeam_channel::Sender;
use employees::{Connect, Context, ControlFlow, Error, Worker};
use minuteurs::{Timer, Watcher};

use crate::aggregator::AggregatorContext;
use crate::messages::AggregatorMessage;

/* ---------- */

pub(crate) struct MyWorker {
    period: Watcher,
    to_aggreg: Sender<AggregatorMessage>,
}

impl Worker for MyWorker {
    fn on_update(&mut self) -> ControlFlow {
        if self.period.has_ticked() {
            println!("sending data to the aggregator");

            if let Err(err) = self.to_aggreg.send(AggregatorMessage::Data) {
                println!("failed to data to the aggregator: {err}")
            }
        }

        ControlFlow::Continue
    }
}

/* ---------- */

#[derive(Default)]
pub(crate) struct MyWorkerContext {
    period: Option<Watcher>,
    to_aggreg: Option<Sender<AggregatorMessage>>,
}

impl Context for MyWorkerContext {
    type Target = MyWorker;

    fn into_worker(self) -> Result<Self::Target, Error> {
        let period = self.period.ok_or(Error::context("period"))?;
        let to_aggreg = self.to_aggreg.ok_or(Error::context("to_aggreg"))?;

        Ok(MyWorker { period, to_aggreg })
    }
}

impl Connect<Timer> for MyWorkerContext {
    fn on_connection(&mut self, recver: Watcher) {
        let _ = self.period.insert(recver);
    }
}

impl Connect<AggregatorContext> for MyWorkerContext {
    fn on_connection(&mut self, endpoint: Sender<AggregatorMessage>) {
        let _ = self.to_aggreg.insert(endpoint);
    }
}