may_rpc 0.1.7

RPC framework for Rust based on coroutine.
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

#[may_rpc::service]
trait RpcSpec {
    fn add(&self, x: u32, y: u32) -> u32;
}

#[derive(may_rpc::Server)]
#[service(RpcSpec)]
struct RcpServer;
impl RpcSpec for RcpServer {
    fn add(&self, _x: u32, _y: u32) -> u32 {
        panic!("panic in side")
    }
}

fn main() {
    use may_rpc::TcpServer;
    let addr = ("127.0.0.1", 4000);
    let _server = RcpServer.start(addr).unwrap();

    let stream = may::net::TcpStream::connect(addr).unwrap();
    let client = RpcSpecClient::new(stream).unwrap();
    println!("rsp = {:?}", client.add(1, 4));
    // assert_eq!(client.add(1, 4).is_err(), true);
    println!("done");
}