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

use std::time::Duration;

use lakka::*;

#[derive(Debug, Clone)]
pub struct Connected;

#[derive(Debug, Clone)]
pub struct Happy;

#[derive(Debug, Clone)]
pub struct Disconnected;

#[derive(Debug)]
pub struct Connection<State, Feel> {
    _state: State,
    _feel: Feel,
}

#[messages]
impl Connection<Connected, Happy> {
    pub fn disconnect(
        &mut self,
    ) -> connection_disconnected_happy::ConnectionHandle<Disconnected, Happy> {
        Connection {
            _state: Disconnected,
            _feel: Happy,
        }
        .run()
    }
}

#[messages]
impl Connection<Disconnected, Happy> {
    pub fn connect(&self) -> connection_connected_happy::ConnectionHandle<Connected, Happy> {
        Connection {
            _state: Connected,
            _feel: Happy,
        }
        .run()
    }
}

#[tokio::main]
async fn main() {
    let con = Connection {
        _state: Connected,
        _feel: Happy,
    };
    let handle = con.run();
    let d = handle.disconnect().await.unwrap();
    println!("received disconnect",);

    drop(handle);
    let _k = d.connect().await;
    println!("received connected");

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