plyne 0.2.0

Based pipeline of async task system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use tokio::sync::oneshot;

use crate::{Input, Output};

pub type Function<Args, Ret> = Input<FnEevent<Args, Ret>>;
pub type FunctionHandler<Args, Ret> = Output<FnEevent<Args, Ret>>;
pub type FnEevent<Args, Ret> = (Args, oneshot::Sender<Ret>);

pub trait FnPipeline<Args, Ret> {
    fn call(&self, args: Args) -> impl Future<Output = Ret>;
}

impl<Args, Ret> FnPipeline<Args, Ret> for Function<Args, Ret> {
    async fn call(&self, args: Args) -> Ret {
        let (sender, receiver) = oneshot::channel();
        self.send((args, sender)).unwrap();
        receiver.await.unwrap()
    }
}