Struct MobileRpcClient 

pub struct MobileRpcClient { /* private fields */ }

Available on crate feature client only.

Mobile RPC Client (16-byte header protocol)

Use this for connecting to mobile-optimized servers. Mobile RPC Client implementation

Similar to BaseRpcClient but uses mobile 16-byte protocol.

Example

let client = MobileRpcClient::new("tcp://localhost:9528").await?;
let response = client.sync_call("MyService.echo", params, 5000).await?;

Implementations

impl MobileRpcClient

pub async fn new(path: &str) -> Result<MobileRpcClient, ZusError>

Create client connecting to one or more servers

Arguments

• path - Server path in format “tcp://host1:port1,host2:port2”

Example

let client = MobileRpcClient::new("tcp://localhost:9528").await?;

pub async fn connect(host: &str, port: u16) -> Result<MobileRpcClient, ZusError>

Create client connecting to a single server

pub fn builder() -> MobileRpcClientBuilder

Create a builder for more advanced configuration

Trait Implementations

impl MobileZusRpcClient for MobileRpcClient

fn sync_call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, request: Bytes, timeout_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<Bytes, ZusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MobileRpcClient: 'async_trait,

Synchronous RPC call

fn notify_call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, request: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), ZusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MobileRpcClient: 'async_trait,

Asynchronous RPC call (fire and forget)

fn send_heartbeat<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), ZusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MobileRpcClient: 'async_trait,

Send heartbeat