atomr-macros 0.9.2

Procedural macros for atomr — `#[derive(Actor)]`, `props!`, `#[derive(Receive)]`.
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

//! Phase 1.E — `props!` macro.
//!
//! Verifies that `props!(Foo { ... })` expands to a `Props<Foo>` that
//! can be passed to `ActorSystem::actor_of`.

use atomr_config::Config;
use atomr_core::actor::{Actor, ActorSystem, Context};
use atomr_macros::props;
use std::time::Duration;
use tokio::sync::oneshot;

struct Greeter {
    prefix: String,
}

enum GreeterMsg {
    Hello(String, oneshot::Sender<String>),
}

#[async_trait::async_trait]
impl Actor for Greeter {
    type Msg = GreeterMsg;
    async fn handle(&mut self, _ctx: &mut Context<Self>, msg: GreeterMsg) {
        match msg {
            GreeterMsg::Hello(name, reply) => {
                let _ = reply.send(format!("{}, {}", self.prefix, name));
            }
        }
    }
}

#[tokio::test]
async fn props_macro_creates_actor() {
    let sys = ActorSystem::create("PropsMacro", Config::reference()).await.unwrap();
    let greeter = sys.actor_of(props!(Greeter { prefix: "hi".into() }), "g").unwrap();
    let reply = greeter
        .ask_with(|tx| GreeterMsg::Hello("world".into(), tx), Duration::from_millis(200))
        .await
        .unwrap();
    assert_eq!(reply, "hi, world");
    sys.terminate().await;
}