jsonrpc-v2 0.13.0

JSONRPC 2.0 server
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

use actix_web_v4::{guard, web, App, HttpServer};
use jsonrpc_v2::{Error, Params, Server};
use std::rc::Rc;

async fn add(x: &usize, y: &usize) -> usize {
    x + y
}

async fn non_send(Params(params): Params<usize>) -> Result<usize, Error> {
    // Using a Rc to make sure this async block returns a future that is ?Send
    let foo: Rc<usize> = Rc::new(1);
    Ok(add(&params, foo.as_ref()).await)
}

#[tokio::main]
async fn main() -> std::io::Result<()> {
    let rpc = Server::new().with_method("non_send", non_send).finish();

    HttpServer::new(move || {
        let rpc = rpc.clone();
        App::new().service(web::service("/api").guard(guard::Post()).finish(rpc.into_web_service()))
    })
    .bind("0.0.0.0:3000")?
    .run()
    .await
}