zestors-request 0.0.1

A fast, flexible and extensible actor-framework.
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

#![doc = include_str!("../README.md")]

use std::marker::PhantomData;
use tokio::sync::oneshot;
use zestors_core::messaging::MessageType;

mod into_recv;
mod tx_rx;

pub use {into_recv::*, tx_rx::*};

//------------------------------------------------------------------------------------------------
//  Request
//------------------------------------------------------------------------------------------------

#[derive(Debug, Clone, Copy)]
pub struct Request<T>(PhantomData<T>);

impl<T> Request<T> {
    pub fn create() -> (Tx<T>, Rx<T>) {
        let (tx, rx) = oneshot::channel();
        (Tx(tx), Rx(rx))
    }
}

impl<M, R> MessageType<M> for Request<R> {
    type Sends = (M, Tx<R>);
    type Returns = Rx<R>;

    fn create(msg: M) -> ((M, Tx<R>), Rx<R>) {
        let (tx, rx) = Request::create();
        ((msg, tx), rx)
    }

    fn destroy(sends: (M, Tx<R>), _returns: Rx<R>) -> M {
        sends.0
    }
}