blob: 8e0972bc8608fae494ef7565a539a1e2ace2de59 [file] [log] [blame]
use jsonrpc_core;
use jsonrpc_core::{BoxFuture, IoHandler, Result};
use jsonrpc_derive::rpc;
#[rpc]
pub trait Rpc<One, Two> {
/// Get One type.
#[rpc(name = "getOne")]
fn one(&self) -> Result<One>;
/// Adds two numbers and returns a result
#[rpc(name = "setTwo")]
fn set_two(&self, a: Two) -> Result<()>;
/// Performs asynchronous operation
#[rpc(name = "beFancy")]
fn call(&self, a: One) -> BoxFuture<Result<(One, Two)>>;
}
struct RpcImpl;
impl Rpc<u64, String> for RpcImpl {
fn one(&self) -> Result<u64> {
Ok(100)
}
fn set_two(&self, x: String) -> Result<()> {
println!("{}", x);
Ok(())
}
fn call(&self, num: u64) -> BoxFuture<Result<(u64, String)>> {
Box::pin(jsonrpc_core::futures::future::ready(Ok((num + 999, "hello".into()))))
}
}
fn main() {
let mut io = IoHandler::new();
let rpc = RpcImpl;
io.extend_with(rpc.to_delegate())
}