sprite-core 0.1.0

Sprite Engine — a fault-tolerant actor runtime 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

use sprite_core::{Engine, Message};

fn main() {
    let engine = Engine::new();

    let counter = engine.spawn("counter", |ctx| {
        let count = ctx.use_state("count", 0i64);

        ctx.on_message(move |msg| {
            match msg.as_str() {
                Some("inc") => {
                    count.update(|c| c + 1);
                    println!("count = {}", count.get());
                }
                Some("dec") => {
                    count.update(|c| c - 1);
                    println!("count = {}", count.get());
                }
                Some("panic") => {
                    panic!("user-triggered panic");
                }
                _ => {}
            }
        });

        ctx.on_panic(|| {
            println!("Counter recovered! State is intact.");
        });
    });

    std::thread::sleep(std::time::Duration::from_millis(20));

    counter.send(Message::text("inc"));
    counter.send(Message::text("inc"));
    counter.send(Message::text("dec"));
    counter.send(Message::text("panic"));
    counter.send(Message::text("inc"));

    std::thread::sleep(std::time::Duration::from_millis(200));
}