Struct eva_sdk::prelude::RpcClient

pub struct RpcClient { /* private fields */ }

Implementations

impl RpcClient

pub fn new<H>(client: impl AsyncClient + 'static, handlers: H) -> RpcClientwhere H: RpcHandlers + Send + Sync + 'static,

creates RPC client with the specified handlers and the default options

pub fn new0(client: impl AsyncClient + 'static) -> RpcClient

creates RPC client with dummy handlers and the default options

pub fn create<H>( client: impl AsyncClient + 'static, handlers: H, opts: Options ) -> RpcClientwhere H: RpcHandlers + Send + Sync + 'static,

creates RPC client

pub fn create0(client: impl AsyncClient + 'static, opts: Options) -> RpcClient

creates RPC client with dummy handlers

Trait Implementations

impl Drop for RpcClient

fn drop(&mut self)

Executes the destructor for this type.

impl Rpc for RpcClient

fn call<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target: &'life1 str, method: &'life2 str, params: Cow<'async_trait>, qos: QoS ) -> Pin<Box<dyn Future<Output = Result<RpcEvent, RpcError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RpcClient: 'async_trait,

Panics

Will panic on poisoned mutex

fn client(&self) -> Arc<Mutex<dyn AsyncClient + 'static>>

When created, busrt client is wrapped with Arc<Mutex<_>> to let it be sent into the incoming frames handler future

fn notify<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 str, data: Cow<'async_trait>, qos: QoS ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, RpcClient: 'async_trait,

fn call0<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target: &'life1 str, method: &'life2 str, params: Cow<'async_trait>, qos: QoS ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RpcClient: 'async_trait,

Call the method, no response is required

fn is_connected(&self) -> bool