Struct RpcServer

pub struct RpcServer<'a, StreamError, const MAX_CLIENTS: usize = DEFAULT_MAX_CLIENTS, const MAX_HANDLERS: usize = DEFAULT_MAX_HANDLERS, const MAX_MESSAGE_LEN: usize = DEFAULT_MAX_MESSAGE_LEN, const HANDLER_STACK_SIZE: usize = DEFAULT_HANDLER_STACK_SIZE, const NOTIFICATION_QUEUE_SIZE: usize = DEFAULT_NOTIFICATION_QUEUE_SIZE> { /* private fields */ }

RPC server

Implementations

impl<'a, StreamError, const MAX_CLIENTS: usize, const MAX_HANDLERS: usize, const MAX_MESSAGE_LEN: usize, const HANDLER_STACK_SIZE: usize, const NOTIFICATION_QUEUE_SIZE: usize> RpcServer<'a, StreamError, MAX_CLIENTS, MAX_HANDLERS, MAX_MESSAGE_LEN, HANDLER_STACK_SIZE, NOTIFICATION_QUEUE_SIZE>

pub fn new() -> Self

Create a new RPC server

pub fn register_handler( &mut self, method_name_glob: &'a str, handler: &'a dyn RpcHandler<HANDLER_STACK_SIZE>, ) -> Result<(), RpcServerError<StreamError>>

Register a new RPC method and its handler

pub async fn notify( &self, notification_json: &[u8], ) -> Result<(), RpcServerError<StreamError>>

Broadcast a message to all connected clients.

pub async fn serve<Stream: Read<Error = StreamError> + Write<Error = StreamError>>( &self, stream: &mut Stream, ) -> Result<(), RpcServerError<StreamError>>

Serve requests using the given stream.

Trait Implementations

impl<StreamError, const MAX_CLIENTS: usize, const MAX_HANDLERS: usize, const MAX_MESSAGE_LEN: usize, const HANDLER_STACK_SIZE: usize, const NOTIFICATION_QUEUE_SIZE: usize> Default for RpcServer<'_, StreamError, MAX_CLIENTS, MAX_HANDLERS, MAX_MESSAGE_LEN, HANDLER_STACK_SIZE, NOTIFICATION_QUEUE_SIZE>

fn default() -> Self

Returns the “default value” for a type.