Struct RpcClient

pub struct RpcClient<T, P>
where
    T: UOwnedTransport + ?Sized,
    P: LocalUriProvider + ?Sized,
{ /* private fields */ }

RPC client implemented over an owned native-frame transport.

Implementations

impl<T, P> RpcClient<T, P>

where T: UOwnedTransport + ?Sized, P: LocalUriProvider + ?Sized,

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

Creates an RPC client over an owned native-frame transport.

pub async fn invoke_method( &self, method: UUri, call_options: CallOptions, payload: Option<UPayload>, ) -> Result<Option<UPayload>, ServiceInvocationError>

Invokes an RPC method using owned native frames.

impl<T, P> RpcClient<T, P>

where T: UOwnedTransport + UHasWire + ?Sized, P: LocalUriProvider + ?Sized,

pub async fn invoke_typed<Request, Response>( &self, method: UUri, call_options: CallOptions, request: &Request, ) -> Result<Response, ServiceInvocationError>

where T::Wire: UWireEncode<Request> + UWireDecodeOwned<Response>,

Invokes an RPC method using the transport endpoint’s selected wire.

Trait Implementations

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

where T: UOwnedTransport + ?Sized, P: LocalUriProvider + ?Sized,

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

Formats the value using the given formatter.

impl<T, P> RpcClient for RpcClient<T, P>

where T: UOwnedTransport + ?Sized + 'static, P: LocalUriProvider + ?Sized,

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.