librpc 0.1.2

Generic rpc framework 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
32
33
34
35
36
37
38

pub mod dispatcher;
pub mod responder;

#[cfg(test)]
mod tests {
    use std::time::Duration;

    use async_timer_rs::{hashed::Timeout, Timer};
    use futures::channel::mpsc::SendError;
    use thiserror::Error;

    use crate::dispatcher::Dispatcher;

    #[derive(Debug, Error)]
    enum TestError {
        #[error(transparent)]
        SendError(#[from] SendError),

        #[error(transparent)]
        IO(#[from] std::io::Error),
    }

    #[futures_test::test]
    async fn test_timeout() {
        let (mut dispatcher, _receiver) = Dispatcher::<String, String, TestError>::new(100);

        dispatcher
            .call(
                0,
                "hello".to_owned(),
                Some(Timeout::new(Duration::from_secs(2))),
            )
            .await
            .unwrap()
            .await
            .expect_err("Timeout expect");
    }
}