Struct grpcio::Client

pub struct Client { /* private fields */ }

A generic client for making RPC calls.

Implementations

impl Client

pub fn new(channel: Channel) -> Client

Initialize a new Client.

pub fn unary_call<Req, Resp: Unpin>(
    &self,
    method: &Method<Req, Resp>,
    req: &Req,
    opt: CallOption
) -> Result<Resp>

Create a synchronized unary RPC call.

It uses futures_executor::block_on to wait for the futures. It’s recommended to use the asynchronous version.

pub fn unary_call_async<Req, Resp>(
    &self,
    method: &Method<Req, Resp>,
    req: &Req,
    opt: CallOption
) -> Result<ClientUnaryReceiver<Resp>>

Create an asynchronized unary RPC call.

pub fn client_streaming<Req, Resp>(
    &self,
    method: &Method<Req, Resp>,
    opt: CallOption
) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)>

Create an asynchronized client streaming call.

Client can send a stream of requests and server responds with a single response.

pub fn server_streaming<Req, Resp>(
    &self,
    method: &Method<Req, Resp>,
    req: &Req,
    opt: CallOption
) -> Result<ClientSStreamReceiver<Resp>>

Create an asynchronized server streaming call.

Client sends on request and server responds with a stream of responses.

pub fn duplex_streaming<Req, Resp>(
    &self,
    method: &Method<Req, Resp>,
    opt: CallOption
) -> Result<(ClientDuplexSender<Req>, ClientDuplexReceiver<Resp>)>

Create an asynchronized duplex streaming call.

Client sends a stream of requests and server responds with a stream of responses. The response stream is completely independent and both side can be sending messages at the same time.

pub fn spawn<F>(&self, f: F) where
    F: Future<Output = ()> + Send + 'static, 

Spawn the future into current gRPC poll thread.

This can reduce a lot of context switching, but please make sure there is no heavy work in the future.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.