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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

use crate::tactix::{Actor, Envelope, EnvelopeInner, EnvelopeSender, Handler, Message, Sender, ToEnvelope};
use async_trait::async_trait;
use tokio::sync::{mpsc, oneshot};

/// AddrSender is a Sender that is bound to the Given Actor and can only send messages for that
/// specific Actor on it's Envelope sender.
pub struct AddrSender<A:Actor> {
    tx: mpsc::Sender<Envelope<A>>,
}

impl<A:Actor> Clone for AddrSender<A> {
    fn clone(&self) -> Self {
        AddrSender::new(self.tx.clone())
    }
}

impl<A: Actor> AddrSender<A> {
    pub fn new(tx: mpsc::Sender<Envelope<A>>) -> Self {
        Self { tx }
    }
}

impl<A> EnvelopeSender<A> for AddrSender<A>
where
    A: Actor,
{
    fn get_tx(&self) -> mpsc::Sender<Envelope<A>> {
        self.tx.clone()
    }
}

impl<A, M> ToEnvelope<A, M> for AddrSender<A>
where
    A: Actor + Handler<M>,
    M: Message,
{
    fn pack(&self, msg: Option<M>, tx: Option<oneshot::Sender<M::Response>>) -> Envelope<A> {
        Envelope::new(Box::new(EnvelopeInner { msg, tx }))
    }
}

#[async_trait]
impl<A, M> Sender<M> for AddrSender<A>
where
    A: Actor + Handler<M>,
    M: Message,
{
    /// Pack and send the given message without a return channel via AddrSender<A>'s internal Envelope<A> sender.
    fn do_send(&self, msg: M) {
        self.send_env(self.pack(Some(msg), None))
    }

    /// Pack and send the given message with a return channel via AddrSender<A>'s internal Envelope<A> sender.
    async fn send(&self, msg: M) -> Result<M::Response, String> {
        println!("SEND");
        // make a oneshot
        let (tx, rx) = oneshot::channel::<M::Response>();

        // pass it to the envelope
        self.send_env(self.pack(Some(msg), Some(tx)));

        // receive on the oneshot
        Ok(rx
            .await
            .map_err(|_| "Error receiving response".to_string())?)
    }
}