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
57

use xtra::prelude::*;

struct Initialized(Address<ActorA>);

struct Hello;

#[derive(xtra::Actor)]
struct ActorA {
    actor_b: Address<ActorB>,
}

impl Handler<Hello> for ActorA {
    type Return = ();

    async fn handle(&mut self, _: Hello, ctx: &mut Context<Self>) {
        println!("ActorA: Hello");
        xtra::join(ctx.mailbox(), self, self.actor_b.send(Hello))
            .await
            .unwrap();
    }
}

#[derive(xtra::Actor)]
struct ActorB;

impl Handler<Initialized> for ActorB {
    type Return = ();

    async fn handle(&mut self, m: Initialized, ctx: &mut Context<Self>) {
        println!("ActorB: Initialized");
        let actor_a = m.0;
        xtra::join(ctx.mailbox(), self, actor_a.send(Hello))
            .await
            .unwrap();
    }
}

impl Handler<Hello> for ActorB {
    type Return = ();

    async fn handle(&mut self, _: Hello, _: &mut Context<Self>) {
        println!("ActorB: Hello");
    }
}

fn main() {
    smol::block_on(async {
        let actor_b = xtra::spawn_smol(ActorB, Mailbox::unbounded());
        let actor_a = xtra::spawn_smol(
            ActorA {
                actor_b: actor_b.clone(),
            },
            Mailbox::unbounded(),
        );
        actor_b.send(Initialized(actor_a.clone())).await.unwrap();
    })
}