Struct GrpcClientConn 

pub struct GrpcClientConn<Req, Resp> { /* private fields */ }

Available on crate feature client only.

An owned, typed gRPC client call.

Construct one through a generated <Service>Client method (or new), then drive it with send / close_send / recv. Initial and trailing response metadata are available via headers / trailers once they’ve arrived — on the error path too.

Implementations

impl<Req, Resp> GrpcClientConn<Req, Resp>

where Req: Send + 'static, Resp: Send + 'static,

pub fn new<C>( client: &Client, path: &str, metadata: Metadata, timeout: Option<Duration>, full_duplex: bool, ) -> Self

where C: Codec<Req> + Codec<Resp>,

Open a call over codec C, deriving the content-type and encode/decode from the Codec impl and the outbound compression from the client’s configured grpc-encoding. No network I/O happens until close_send or the first recv.

pub fn cancel_handle(&self) -> CancelHandle

A cancellation handle for this call. Clone it freely; calling cancel on any clone cancels this RPC.

pub fn headers(&self) -> Option<&Headers>

The response’s initial metadata, available once the head has arrived (after the first recv, or after close_send for half-duplex). None before then.

pub fn trailers(&self) -> Option<&Headers>

The response’s trailing metadata, available once the response stream has ended. None before end-of-stream.

pub async fn send(&mut self, message: Req) -> Result<(), Status>

Frame and send one request message.

Before the request has fired (the common case for half-duplex), this accumulates the frame into the request body. Once a full-duplex call is live, it writes the frame on the wire immediately.

pub async fn close_send(&mut self) -> Result<(), Status>

Half-close the request side (sends END_STREAM).

For send-then-receive shapes this is what fires the request: the accumulated body is sent with END_STREAM and the response head is awaited. For a live full-duplex call it closes the write half, leaving the read side open.

pub async fn recv(&mut self) -> Result<Option<Resp>, Status>

Read the next response message: Ok(Some) for a message, Ok(None) at a clean end-of-stream (grpc-status: 0), Err for an RPC error (which also ends the stream). Trailing metadata is available via trailers afterward.