lakka 0.1.0

Simple actors with macros
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

use std::time::Duration;

use duration_helper::DurationHelper;
use lakka::*;

#[derive(Debug, Clone)]
pub struct EverySecond {
    msg: String,
}
pub struct Test(tokio::time::Instant);

#[messages]
impl Test {
    fn interval_test(&mut self, msg: IntervalMessage<EverySecond>) {
        println!(
            "---- Received interval_test {:?}, count {}, msg: {:?}",
            self.0.elapsed(),
            msg.counter,
            msg.msg
        );
        self.0 = tokio::time::Instant::now();
    }

    fn test(&self) {
        println!("TEST!");
    }

    fn start_interval_test(&mut self) {
        let channel = Intervaller::new(
            1.secs(),
            TestTellMessage::IntervalTest,
            EverySecond {
                msg: "noice".into(),
            },
        );
        _ctx.add_channel(Box::new(channel));
    }
}

#[tokio::main]
async fn main() {
    let handle = Test(tokio::time::Instant::now()).run();
    _ = handle.test().await;
    tokio::time::sleep(Duration::from_secs(2)).await;
    _ = handle.start_interval_test().await;
    tokio::time::sleep(Duration::from_secs(60)).await;
}