fibers_rpc

Rust RPC library built on top of [fibers] crate.

Documentation

Examples

Simple echo RPC server: ```rust use fibers::{Executor, InPlaceExecutor, Spawn}; use fibersrpc::{Call, ProcedureId}; use fibersrpc::client::RpcClientServiceBuilder; use fibersrpc::codec::BytesEncoder; use fibersrpc::server::{HandleCall, Reply, RpcServerBuilder}; use futures::Future;

// RPC definition struct EchoRpc; impl Call for EchoRpc { const ID: ProcedureId = ProcedureId(0); const NAME: &'static str = "echo";

type Req = Vec<u8>;
type ReqEncoder = BytesEncoder<Vec<u8>>;
type ReqDecoder = Vec<u8>;

type Res = Vec<u8>;
type ResEncoder = BytesEncoder<Vec<u8>>;
type ResDecoder = Vec<u8>;

}

// Executor let mut executor = InPlaceExecutor::new().unwrap();

// RPC server struct EchoHandler; impl HandleCall for EchoHandler { fn handlecall(&self, request: ::Req) -> Reply { Reply::done(request) } } let serveraddr = "127.0.0.1:1919".parse().unwrap(); let server = RpcServerBuilder::new(serveraddr) .callhandler(EchoHandler) .finish(executor.handle()); executor.spawn(server.map_err(|e| panic!("{}", e)));

// RPC client let service = RpcClientServiceBuilder::new().finish(executor.handle());

let request = Vec::from(&b"hello"[..]); let response = EchoRpc::client(&service.handle()).call(server_addr, request.clone());

executor.spawn(service.maperr(|e| panic!("{}", e))); let result = executor.runfuture(response).unwrap(); assert_eq!(result.ok(), Some(request)); ```