Struct InMemoryRpcServer

pub struct InMemoryRpcServer<T, P> { /* 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<T: UTransport, P: LocalUriProvider> InMemoryRpcServer<T, P>

pub fn new(transport: Arc<T>, uri_provider: Arc<P>) -> Self

Creates a new RPC server for a given transport.

Trait Implementations

impl<T, P> Debug for InMemoryRpcServer<T, P>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: UTransport + 'static, P: LocalUriProvider> RpcServer for InMemoryRpcServer<T, P>

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.