xtra 0.6.0

A tiny actor framework
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
53
54
55
56

//! Set the SMOL_THREADS environment variable to have more threads, else each receiving task will
//! switch only after it has received many messages.

use std::time::Duration;

use xtra::prelude::*;
use xtra::Mailbox;

#[derive(xtra::Actor)]
struct Printer {
    times: usize,
    id: usize,
}

impl Printer {
    fn new(id: usize) -> Self {
        Printer {
            times: 0,
            id: id + 1,
        }
    }
}

struct Print(String);

impl Handler<Print> for Printer {
    type Return = ();

    async fn handle(&mut self, print: Print, ctx: &mut Context<Self>) {
        self.times += 1;
        println!(
            "Printing {} from printer {}. Printed {} times so far.",
            print.0, self.id, self.times
        );

        if self.times == 10 {
            println!("Actor {} stopping!", self.id);
            ctx.stop_all();
        }
    }
}

#[smol_potat::main]
async fn main() {
    let (addr, mailbox) = Mailbox::bounded(32);
    smol::spawn(xtra::run(mailbox.clone(), Printer::new(0))).detach();
    smol::spawn(xtra::run(mailbox.clone(), Printer::new(1))).detach();
    smol::spawn(xtra::run(mailbox.clone(), Printer::new(2))).detach();
    smol::spawn(xtra::run(mailbox, Printer::new(3))).detach();

    while addr.send(Print("hello".to_string())).await.is_ok() {}
    println!("Stopping to send");

    // Give a second for everything to shut down
    std::thread::sleep(Duration::from_secs(1));
}