Struct RpcServer

pub struct RpcServer<'a, const MAX_CLIENTS: usize = DEFAULT_MAX_CLIENTS, const MAX_HANDLERS: usize = DEFAULT_MAX_HANDLERS, const MAX_MESSAGE_LEN: usize = DEFAULT_MAX_MESSAGE_LEN, const STACK_SIZE: usize = DEFAULT_STACK_SIZE> { /* private fields */ }

RPC server

Implementations

impl<'a, const MAX_CLIENTS: usize, const MAX_HANDLERS: usize, const MAX_MESSAGE_LEN: usize, const STACK_SIZE: usize> RpcServer<'a, MAX_CLIENTS, MAX_HANDLERS, MAX_MESSAGE_LEN, STACK_SIZE>

pub fn new() -> Self

Create a new RPC server

pub fn register_method( &mut self, name: &'a str, handler: &'a dyn RpcHandler<STACK_SIZE>, ) -> Result<(), RpcServerError>

Register a new RPC method and its handler

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

Broadcast a message to all connected clients.

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

Serve requests using the given stream.

Trait Implementations

impl<'a, const MAX_CLIENTS: usize, const MAX_HANDLERS: usize, const MAX_MESSAGE_LEN: usize, const STACK_SIZE: usize> Default for RpcServer<'a, MAX_CLIENTS, MAX_HANDLERS, MAX_MESSAGE_LEN, STACK_SIZE>

fn default() -> Self

Returns the “default value” for a type.