xacto 0.1.0

Simple Erlang-style actors for Rust.
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

use async_trait::async_trait;
use serde::{Deserialize, Serialize};

use crate::{Act, ReplyMap};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RpcEnvelope<T> {
    pub id: usize,
    pub payload: T,
}

#[async_trait]
pub trait RpcMessage {
    type Request;
    type Response;

    fn into_request(self, proxy: &mut ReplyMap) -> RpcEnvelope<Self::Request>;

    async fn proxy_request<F>(
        env: RpcEnvelope<Self::Request>,
        f: F,
    ) -> Result<Option<RpcEnvelope<Self::Response>>, ()>
    where
        F: FnOnce(Self) -> Option<(Self, Act<Self>)>,
        Self: Sized;

    async fn proxy_response(
        env: RpcEnvelope<Self::Response>,
        proxy: &mut ReplyMap,
    ) -> Result<(), ()>;
}