actor12 0.0.9

A lightweight actor framework for Rust with async support
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 actor12::Actor;
use actor12::Call;
use actor12::Handler;
use actor12::Init;
use actor12::MpscChannel;
use actor12::Multi;
use actor12::prelude::InitFuture;
use futures::future;

struct MultiActor {}

impl Actor for MultiActor {
    type Cancel = ();
    type State = ();
    type Channel = MpscChannel<Self::Message>;
    type Message = Multi<Self>;
    type Spec = ();

    fn state(_: &Self::Spec) -> Self::State {
        ()
    }

    fn init(_: Init<'_, Self>) -> impl InitFuture<Self> {
        future::ready(Ok(MultiActor {}))
    }
}

impl Handler<String> for MultiActor {
    type Reply = Result<String, anyhow::Error>;

    async fn handle(&mut self, _ctx: Call<'_, Self, Self::Reply>, _: String) -> Self::Reply {
        Ok("Hello".to_string())
    }
}

#[tokio::test]
async fn test() {
    let link = actor12::spawn::<MultiActor>(());

    let value = link.ask_dyn("Test message".to_string()).await;
    assert_eq!(value.unwrap(), "Hello".to_string());
}