Struct eva_sdk::prelude::RpcClient

pub struct RpcClient { /* private fields */ }

Implementations

impl RpcClient

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

Panics

Should not panic

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

Panics

Should not panic

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, elbus 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