Struct Server 

pub struct Server<C> { /* private fields */ }

A JSON-RPC 2.0 server.

Generic over a context type C that is cloned once per handler invocation.

Example

use jsonrpc::{Server, Error};

let mut server = Server::new();
server.register("add", |_: (), (a, b): (i64, i64)| async move {
    Ok::<_, Error>(a + b)
});

Implementations

impl<C: Send + Sync + 'static> Server<C>

pub fn new() -> Self

Creates a new server with no registered methods.

pub fn register<P, R, E, F>( &mut self, method: impl Into<String>, handler: impl Fn(C, P) -> F + Send + Sync + 'static, )

where P: DeserializeOwned + Send + 'static, R: Serialize + Send + 'static, E: Into<Error> + Send + 'static, F: Future<Output = Result<R, E>> + Send + 'static,

Registers an async handler for the given method name.

The handler receives an owned clone of the context and deserialized method parameters, and returns a future.

pub async fn handle(&self, ctx: C, message: RequestMessage) -> ResponseMessage

where C: Clone,

Handles a request message and returns the corresponding response message.

The context ctx is consumed and, for batches, cloned once per handler invocation.