actm 0.2.0

Tiny async actors framework for rust
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

use std::collections::BTreeMap;

use actm::prelude::*;

// First we define the context type

#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash, Debug, Default)]
pub struct UniversityContext {
    /// The students and their current grades
    pub students: BTreeMap<String, Vec<u32>>,
}

// Then the input type

#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash, Debug)]
pub enum UniversityInput {
    Get,
    Grade(String, u32),
}

// Then the output type

#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash, Debug)]
pub struct UniversityOutput(pub BTreeMap<String, Vec<u32>>);

wrapped_event!(UniversityOutputEvent, UniversityOutput);
wrapped_event!(UniveristyInputEvent, UniversityInput);

async fn university_event_handler(
    mut context: UniversityContext,
    event: UniveristyInputEvent,
) -> (UniversityContext, Option<UniversityOutputEvent>) {
    match event.into_inner() {
        UniversityInput::Grade(student, grade) => {
            let grades = context.students.entry(student).or_default();
            grades.push(grade);
            (context, None)
        }
        UniversityInput::Get => {
            let event = UniversityOutputEvent::from(UniversityOutput(context.students.clone()));
            (context, Some(event))
        }
    }
}

async_actor!(
    University,
    UniveristyInputEvent,
    UniversityOutputEvent,
    UniversityContext,
    university_event_handler
);