Struct GrpcServerConn 

pub struct GrpcServerConn<C = Prost> { /* private fields */ }

Available on crate feature server only.

The control surface for a single gRPC call. Owns the Conn for the duration of one RPC — value in, value out.

Implementations

impl<C> GrpcServerConn<C>

pub fn received_headers(&self) -> &Headers

The request’s initial metadata (received headers), including any custom metadata the client attached.

pub fn response_headers_mut(&mut self) -> &mut Headers

The response’s initial metadata, written straight through to the Conn. Committed to the wire when the handler returns, before the first response byte.

pub fn response_trailers_mut(&mut self) -> &mut Headers

The response’s trailing metadata, emitted alongside grpc-status after the response body.

pub fn deadline(&self) -> Option<Instant>

The deadline derived from the request’s grpc-timeout header, if any.

pub fn requests<Req>(&mut self) -> RequestStream<'_, Req>

where C: Codec<Req>, Req: 'static,

A typed stream of decoded request messages.

Borrows the connection for the lifetime of the returned stream; read it to EOF (or drop it) before touching response headers again. The codec’s decode is selected by the GrpcServerConn’s codec parameter, so the only thing you supply is the message type:

let mut reqs = conn.requests::<HelloRequest>();
while let Some(req) = reqs.recv().await? { /* … */ }