Struct FunctionHandler 

pub struct FunctionHandler<F, N, E>
where
    E: Error + Send + Sync + 'static,
    F: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<Value, E>> + Send + Sync,
    N: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<(), E>> + Send + Sync,
{ /* private fields */ }

A simple function-based handler

Implementations

impl<F, N, E> FunctionHandler<F, N, E>

where E: Error + Send + Sync + 'static, F: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<Value, E>> + Send + Sync, N: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<(), E>> + Send + Sync,

pub fn new(handler_fn: F) -> Self

pub fn with_notification_handler(self, notification_fn: N) -> Self

pub fn with_methods(self, methods: Vec<String>) -> Self

Trait Implementations

impl<F, N, E> JsonRpcHandler for FunctionHandler<F, N, E>

where E: Error + Send + Sync + 'static, F: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<Value, E>> + Send + Sync, N: Fn(&str, Option<RequestParams>, Option<SessionContext>) -> BoxFuture<'static, Result<(), E>> + Send + Sync,

type Error = E

The error type returned by this handler

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, params: Option<RequestParams>, session_context: Option<SessionContext>, ) -> Pin<Box<dyn Future<Output = Result<Value, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a JSON-RPC method call with optional session context Returns domain errors only - dispatcher handles conversion to JSON-RPC errors

fn handle_notification<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, params: Option<RequestParams>, session_context: Option<SessionContext>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a JSON-RPC notification with optional session context (optional - default does nothing)

fn supported_methods(&self) -> Vec<String>

List supported methods (optional - used for introspection)