hannibal 0.16.3

A small actor library
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

use hannibal::{Broker, prelude::*};

#[derive(Clone, Message)]
struct Topic1(u32);

#[derive(Debug, Default, PartialEq)]
struct Subscribing(Vec<u32>);

impl Actor for Subscribing {
    async fn started(&mut self, ctx: &mut Context<Self>) -> DynResult<()> {
        ctx.subscribe::<Topic1>().await?;
        Ok(())
    }
}

impl Handler<Topic1> for Subscribing {
    async fn handle(&mut self, ctx: &mut Context<Self>, msg: Topic1) {
        self.0.push(msg.0);
        log::debug!("received {}", msg.0);
        if self.0.len() == 2 {
            ctx.stop().unwrap()
        }
    }
}

#[hannibal::main]
async fn main() {
    env_logger::init();
    let subscriber1 = Subscribing::default().spawn_owning();
    subscriber1.ping().await.unwrap();

    let subscriber2 = Subscribing::default().spawn_owning();
    subscriber2.ping().await.unwrap();

    let broker = Broker::from_registry().await;
    broker.publish(Topic1(42)).await.unwrap();
    broker.publish(Topic1(23)).await.unwrap();

    assert_eq!(subscriber1.consume().await, Ok(Subscribing(vec![42, 23])));
    assert_eq!(subscriber2.consume().await, Ok(Subscribing(vec![42, 23])));
    println!("both subscribers received all messages");
}