Struct InMemoryRpcServer

pub struct InMemoryRpcServer { /* private fields */ }

An RpcServer which keeps all information about registered endpoints in memory.

The server requires an implementations of UTransport for receiving RPC Request messages from clients and sending back RPC Response messages.

For each endpoint being registered, a UListener is created for the given request handler and registered with the underlying transport. The listener is also mapped to the endpoint’s method resource ID in order to prevent registration of multiple request handlers for the same method.

Implementations

impl InMemoryRpcServer

pub fn new( transport: Arc<dyn UTransport>, uri_provider: Arc<dyn LocalUriProvider>, ) -> Self

Creates a new RPC server for a given transport.

Trait Implementations

impl RpcServer for InMemoryRpcServer

fn register_endpoint<'life0, 'life1, 'async_trait>( &'life0 self, origin_filter: Option<&'life1 UUri>, resource_id: u16, request_handler: Arc<dyn RequestHandler>, ) -> Pin<Box<dyn Future<Output = Result<(), RegistrationError>> + Send + 'async_trait>>

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

Registers an endpoint for RPC requests.

fn unregister_endpoint<'life0, 'life1, 'async_trait>( &'life0 self, origin_filter: Option<&'life1 UUri>, resource_id: u16, _request_handler: Arc<dyn RequestHandler>, ) -> Pin<Box<dyn Future<Output = Result<(), RegistrationError>> + Send + 'async_trait>>

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

Deregisters a previously registered endpoint.