tactix 0.0.6

A simple Actor Model based on Tokio.
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

use std::sync::Arc;

use async_trait::async_trait;
use tokio::sync::{oneshot::Sender, Mutex};

use crate::traits::{Actor, EnvelopeApi, Handler, Message};

pub struct EnvelopeInner<M>
where
    M: Message + Send,
{
    pub msg: Option<M>,
    pub tx: Option<Sender<M::Response>>,
}

#[async_trait]
impl<A, M> EnvelopeApi<A> for EnvelopeInner<M>
where
    A: Actor + Handler<M>,
    M: Message,
{
    async fn handle(&mut self, act: Arc<Mutex<A>>, ctx: A::Context) {
        if let Some(msg) = self.msg.take() {
            let res = act.lock().await.handle(msg, ctx).await;
            if let Some(tx) = self.tx.take() {
                let _ = tx.send(res);
            }
        }
    }
}