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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use lakka::*;
use std::time::Duration;

//#[actor]
#[derive(Default)]
struct SimpleTest {
    counter: u32,
    last_value: String,
}

#[messages]
impl SimpleTest {
    pub fn new() -> Self {
        SimpleTest::default()
    }

    fn last_value(&self) -> String {
        self.last_value.clone()
    }

    async fn last_value_async(&self) -> String {
        tokio::time::sleep(Duration::from_millis(15)).await;
        self.last_value.clone()
    }

    fn set_last_value(&mut self, value: String) {
        self.counter += 1;
        self.last_value = value;
    }

    async fn set_last_value_async(&mut self, value: String) {
        self.counter += 1;
        tokio::time::sleep(Duration::from_millis(15)).await;
        self.last_value = value;
    }

    fn print(&self) {
        println!(
            "actor print: {}, altered: {} times",
            self.last_value, self.counter
        );
    }
}

#[tokio::main]
async fn main() -> Result<(), ActorError> {
    //let channel = tokio::sync::mpsc::channel(100);
    let asd = SimpleTest::new().run(); //s(channel);

    asd.set_last_value("innit".into()).await?;
    asd.print().await?;
    asd.set_last_value("monkey".into()).await?;
    asd.set_last_value_async("bononoke".into()).await?;
    let res = asd.last_value().await;
    println!("Got last value: {}", res.unwrap());
    asd.set_last_value("monkey".into()).await?;
    asd.set_last_value("donkey".into()).await?;
    asd.print().await?;
    _ = asd;

    tokio::time::sleep(Duration::from_millis(50)).await;
    Ok(())
}