Struct RpcClient

pub struct RpcClient<Request, Response>
where
    Request: Message,
    Response: Message,
{ /* private fields */ }

A client for sending RPCs to a protosockets rpc server.

It handles sending messages to the server and associating the responses. Messages are sent and received in any order, asynchronously, and support cancellation. To cancel an RPC, drop the response future.

Implementations

impl<Request, Response> RpcClient<Request, Response>

where Request: Message, Response: Message,

pub async fn send_streaming( &self, request: Request, ) -> Result<StreamingCompletion<Response>>

Send a server-streaming rpc to the server.

This function only sends the request. You must consume the completion stream to get the response.

pub async fn send_unary( &self, request: Request, ) -> Result<UnaryCompletion<Response>>

Send a unary rpc to the server.

This function only sends the request. You must await the completion to get the response.

Trait Implementations

impl<Request, Response> Clone for RpcClient<Request, Response>

where Request: Message + Clone, Response: Message + Clone,

fn clone(&self) -> RpcClient<Request, Response>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Request, Response> Debug for RpcClient<Request, Response>

where Request: Message + Debug, Response: Message + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.