atomr-core 0.3.1

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
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

//! Phase 3.7 — `fsm!` declarative macro smoke test.

use atomr_core::actor::FiniteStateMachine;
use atomr_core::fsm;

#[derive(Clone, Eq, PartialEq, Debug)]
enum Light {
    Idle,
    Running,
}

enum Cmd {
    Go,
    Stop,
}

struct Traffic;

fsm! {
    Traffic,
    state = Light,
    data = u32,
    msg = Cmd;
    initial state = Light::Idle, data = 0;
    (Light::Idle, Cmd::Go) => |s, d| (Light::Running, *d + 1, None);
    (Light::Running, Cmd::Stop) => |s, d| (Light::Idle, *d, None);
}

#[test]
fn fsm_macro_drives_transitions() {
    let mut t = Traffic;
    assert_eq!(t.initial_state(), Light::Idle);
    let s1 = t.transition(&Light::Idle, &0, Cmd::Go).unwrap();
    assert_eq!(s1.next, Light::Running);
    assert_eq!(s1.data, 1);
    let s2 = t.transition(&Light::Running, &1, Cmd::Stop).unwrap();
    assert_eq!(s2.next, Light::Idle);
}

#[test]
fn fsm_macro_returns_none_on_unhandled() {
    let mut t = Traffic;
    assert!(t.transition(&Light::Running, &0, Cmd::Go).is_none());
}