tonic-rpc 0.2.1

RPC library that uses native Rust types and is built on tonic.
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

#![cfg(feature = "cbor")]

use tonic_rpc::tonic_rpc;

mod util;

#[tonic_rpc(cbor)]
trait Units {
    fn send(arg: ());
    fn heartbeat();
}

struct State;

#[tonic::async_trait]
impl units_server::Units for State {
    async fn send(&self, _: tonic::Request<()>) -> Result<tonic::Response<()>, tonic::Status> {
        Ok(tonic::Response::new(()))
    }

    async fn heartbeat(&self, _: tonic::Request<()>) -> Result<tonic::Response<()>, tonic::Status> {
        Ok(tonic::Response::new(()))
    }
}

#[tokio::test]
async fn test_unit_in_sig() {
    let addr = util::run_server(units_server::UnitsServer::new(State)).await;
    let mut client = units_client::UnitsClient::connect(addr)
        .await
        .expect("Failed to connect");

    assert_eq!((), client.send(()).await.unwrap().into_inner());
    assert_eq!((), client.heartbeat(()).await.unwrap().into_inner());
}