Struct InMemoryRpcClient

pub struct InMemoryRpcClient<T, P> { /* private fields */ }

An RpcClient which keeps all information about pending requests in memory.

The client requires an implementations of UTransport for sending RPC Request messages to the service implementation and receiving its RPC Response messages.

During startup the client registers a generic UListener with the transport for receiving all kinds of messages with a sink address matching the client. The listener maintains an in-memory mapping of (pending) request IDs to response message handlers.

When an RPC call is made, an RPC Request message is sent to the service implementation and a response handler is created and registered with the listener. When an RPC Response message arrives from the service, the corresponding handler is being looked up and invoked.

Implementations

impl<T: UTransport, P: LocalUriProvider> InMemoryRpcClient<T, P>

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

Creates a new RPC client for a given transport.

Arguments

• transport - The uProtocol Transport Layer implementation to use for invoking service operations.
• uri_provider - The helper for creating URIs that represent local resources.

Errors

Returns an error if the generic RPC Response listener could not be registered with the given transport.

Trait Implementations

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

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

Formats the value using the given formatter.

impl<T: UTransport, P: LocalUriProvider> RpcClient for InMemoryRpcClient<T, P>

fn invoke_method<'life0, 'async_trait>( &'life0 self, method: UUri, call_options: CallOptions, payload: Option<UPayload>, ) -> Pin<Box<dyn Future<Output = Result<Option<UPayload>, ServiceInvocationError>> + Send + 'async_trait>>

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

Invokes a method on a service.