sprite-core 0.1.7

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

use sprite_core::{Engine, Message};

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

    for i in 0..3 {
        engine.spawn(&format!("listener-{}", i), |ctx| {
            let name = ctx.name().to_string();
            ctx.on_message(move |msg| {
                println!("{} got: {:?}", name, msg);
            });
        });
    }

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

    let sent = engine.broadcast(Message::text("hello everyone!"));
    println!("Broadcast to {} actors", sent);

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