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

use std::future::Future;

use actor12::Actor;
use actor12::Envelope;
use actor12::Exec;
use actor12::Init;

struct MyActor {}

impl Actor for MyActor {
    type Cancel = ();
    type State = ();
    type Channel = actor12::MpscChannel<Self::Message>;
    type Message = Envelope<String, anyhow::Result<String>>;
    type Spec = ();

    async fn handle(&mut self, _ctx: Exec<'_, Self>, _msg: Self::Message) {
        _msg.reply.send(Ok("Hello".to_string())).unwrap();
    }

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

    fn init(_ctx: Init<'_, Self>) -> impl Future<Output = Result<Self, Self::Cancel>> + 'static {
        futures::future::ready(Ok(MyActor {}))
    }
}

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

    let value = link.send("Test message".to_string()).await;

    assert_eq!(value.unwrap(), "Hello".to_string());
}