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

use crate::tactix::{Message, Sender};
use async_trait::async_trait;

/// An object that has the ability to send messages of a given type M 
pub struct Recipient<M: Message> {
    tx: Box<dyn Sender<M>>,
}

impl<M> Recipient<M>
where
    M: Message,
{
    pub fn new(tx: Box<dyn Sender<M>>) -> Self {
        Recipient { tx }
    }
}
#[async_trait]
impl<M> Sender<M> for Recipient<M>
where
    M: Message,
{
    fn do_send(&self, msg: M) {
        self.tx.do_send(msg)
    }

    async fn send(&self, msg: M) -> Result<M::Response, String> {
        self.tx.send(msg).await
    }
}