Lines Matching refs:RpcContext
615 pub struct RpcContext<'a> { struct
621 impl<'a> RpcContext<'a> { impl
622 fn new(ctx: RequestContext, cq: &CompletionQueue) -> RpcContext<'_> { in new()
623 RpcContext { in new()
693 ctx: RpcContext<'_>, in execute_unary()
699 F: FnMut(RpcContext<'_>, P, UnarySink<Q>), in execute_unary()
720 ctx: RpcContext<'_>, in execute_client_streaming()
725 F: FnMut(RpcContext<'_>, RequestStream<P>, ClientStreamingSink<Q>), in execute_client_streaming()
738 ctx: RpcContext<'_>, in execute_server_streaming()
744 F: FnMut(RpcContext<'_>, P, ServerStreamingSink<Q>), in execute_server_streaming()
767 ctx: RpcContext<'_>, in execute_duplex_streaming()
772 F: FnMut(RpcContext<'_>, RequestStream<P>, DuplexSink<Q>), in execute_duplex_streaming()
802 let rpc_ctx = RpcContext::new(ctx, cq); in execute()