atticus 0.3.0

A mimimal API to create asynchronous actors
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

use async_trait::async_trait;
use atticus::Actor;

#[derive(Default)]
pub struct TestActor {
    last_message: Option<Message>,
}

#[allow(dead_code)]
#[derive(Debug, PartialEq, Eq, Clone)]
pub enum Message {
    Echo(String),
    AddOne(i32),
    IgnoreThis,
    GetLastRequest,
}

#[derive(Debug, PartialEq, Eq, Clone)]
pub enum ResponseMsg {
    Echo(String),
    Number(i32),
    LastRequest(Option<Message>),
}

#[async_trait]
impl Actor for TestActor {
    type Request = Message;
    type Response = ResponseMsg;

    async fn handle(&mut self, message: Self::Request) -> Option<Self::Response> {
        use Message::*;

        println!("handling message");

        let response = match &message {
            Echo(s) => Some(ResponseMsg::Echo(s.clone())),
            AddOne(i) => Some(ResponseMsg::Number(i + 1)),
            IgnoreThis => None,
            GetLastRequest => Some(ResponseMsg::LastRequest(self.last_message.clone())),
        };

        self.last_message = Some(message);

        response
    }
}