use jsonrpc_http_server::jsonrpc_core::{IoHandler, Value, Params}; use jsonrpc_http_server::ServerBuilder; fn main() { let mut io = IoHandler::default();	io.add_method("say_hello", |_params: Params| async { Ok(Value::String("hello".to_owned())) }); let server = ServerBuilder::new(io) .threads(3) .start_http(&"127.0.0.1:3030".parse().unwrap()) .unwrap();	server.wait(); }

use jsonrpc_core::Result; use jsonrpc_derive::rpc; #[rpc] pub trait Rpc { /// Adds two numbers and returns a result #[rpc(name = "add")] fn add(&self, u64, u64) -> Result<u64>; } pub struct RpcImpl; impl Rpc for RpcImpl { fn add(&self, a: u64, b: u64) -> Result<u64> { Ok(a + b) } } fn main() { let mut io = jsonrpc_core::IoHandler::new();	io.extend_with(RpcImpl.to_delegate()) }

use jsonrpc_core_client::transports::local; use jsonrpc_core::{Error, IoHandler, Result}; use jsonrpc_derive::rpc; /// Rpc trait #[rpc] pub trait Rpc { /// Returns a protocol version #[rpc(name = "protocolVersion")] fn protocol_version(&self) -> Result<String>; /// Adds two numbers and returns a result #[rpc(name = "add", alias("callAsyncMetaAlias"))] fn add(&self, a: u64, b: u64) -> Result<u64>; /// Performs asynchronous operation #[rpc(name = "callAsync")] fn call(&self, a: u64) -> FutureResult<String, Error>; } struct RpcImpl; impl Rpc for RpcImpl { fn protocol_version(&self) -> Result<String> { Ok("version1".into()) } fn add(&self, a: u64, b: u64) -> Result<u64> { Ok(a + b) } fn call(&self, _: u64) -> FutureResult<String, Error> {	future::ok("OK".to_owned()) } } fn main() { let mut io = IoHandler::new();	io.extend_with(RpcImpl.to_delegate()); let fut = { let (client, server) = local::connect::<gen_client::Client, _, _>(io);	client.add(5, 6).map(|res| println!("5 + 6 = {}", res)).join(server) };	fut.wait().unwrap(); }