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> { /* private fields */ }

RPC server

Implementations

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

pub fn new() -> Self

Create a new RPC server

pub fn register_method(&mut self, name: &'a str, handler: RpcHandler)

Register a new RPC method and its handler

pub fn max_message_len(&self) -> usize

Get the maximum message length supported by the server.

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> Default for RpcServer<'a, MAX_CLIENTS, MAX_HANDLERS, MAX_MESSAGE_LEN>

fn default() -> Self

Returns the “default value” for a type.