Struct RpcClient 

pub struct RpcClient {
    pub next_id: Arc<AtomicU64>,
    /* private fields */
}

Fields

next_id: Arc<AtomicU64>

Implementations

impl RpcClient

pub async fn connect( connect_addr: SocketAddr, config: RpcConfig, ) -> Result<Self, RpcError>

pub async fn call( &self, method: &str, params: Vec<u8>, ) -> Result<Vec<u8>, RpcError>

pub async fn call_streaming<S>( &self, method: &str, request_stream: S, ) -> Result<TimeoutStream<impl Stream<Item = Result<Vec<u8>, RpcError>>>, RpcError>

where S: Stream<Item = Vec<u8>> + Send + 'static,

pub async fn call_server_streaming( &self, method: &str, request: Vec<u8>, ) -> Result<TimeoutStream<impl Stream<Item = Result<Vec<u8>, RpcError>>>, RpcError>

pub async fn call_client_streaming<S>( &self, method: &str, request_stream: S, ) -> Result<Vec<u8>, RpcError>

where S: Stream<Item = Vec<u8>> + Send + 'static,