lunatic 0.14.1

Helper library for building Rust applications that run on lunatic.
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

mod counter_abstract_process;

// Import the auto-generated `CounterHandler` public trait.
use counter_abstract_process::{Counter, CounterMessages, CounterRequests};
use lunatic::ap::{AbstractProcess, ProcessRef};
use lunatic::supervisor::{Supervisor, SupervisorConfig, SupervisorStrategy};
use lunatic::Mailbox;

// Supervisor definition.
struct Sup;
impl Supervisor for Sup {
    type Arg = ();
    // Start 1 child and monitor it for failures.
    type Children = (Counter,);

    fn init(config: &mut SupervisorConfig<Self>, _: ()) {
        // If the child fails, just restart it.
        config.set_strategy(SupervisorStrategy::OneForOne);
        // Start child with stat 0
        config.set_args((0,));
        // Name child 'hello'
        config.set_names((Some("hello".to_owned()),));
    }
}

#[lunatic::main]
fn main(_: Mailbox<()>) {
    Sup::start(()).unwrap();

    // Get reference to named child.
    let hello = ProcessRef::<Counter>::lookup(&"hello").unwrap();

    // Accessible `increment` method.
    hello.increment();
    hello.increment();

    assert_eq!(hello.count(), 2);
}