Struct RpcClient 

pub struct RpcClient {
    pub request_id: Arc<AtomicU32>,
    /* private fields */
}

Fields

request_id: Arc<AtomicU32>

Implementations

impl RpcClient

pub fn new(sender: Sender<SendPacket>) -> Self

pub async fn report( &self, business_id: &impl ToBusinessId, data: impl Into<Vec<u8>>, ) -> Result<(), SendError>

Send a request without waiting for a response.

pub async fn send<T>( &self, business_id: &impl ToBusinessId, data: impl Into<Vec<u8>>, timeout: Duration, ) -> Result<T, SendError>

where T: FromBytes,

Send a request and wait for a response.

pub async fn send_stream<T>( &self, business_id: &impl ToBusinessId, data: impl Into<Vec<u8>>, ) -> Result<Stream<T>, SendError>

Send a request and receive a stream of responses.