Searched refs:RpcContext (Results 1 – 5 of 5) sorted by relevance
| /external/rust/crates/grpcio/src/ |
| D | server.rs | 24 use crate::RpcContext;
43 fn handle(&mut self, ctx: RpcContext<'_>, reqs: Option<MessageReader>); in handle()
50 F: FnMut(RpcContext<'_>, Option<MessageReader>) + Send + Clone,
53 fn handle(&mut self, ctx: RpcContext<'_>, reqs: Option<MessageReader>) { in handle()
192 F: FnMut(RpcContext<'_>, Req, UnarySink<Resp>) + Send + Clone + 'static, in add_unary_handler()
195 let h = move |ctx: RpcContext<'_>, payload: Option<MessageReader>| { in add_unary_handler()
212 F: FnMut(RpcContext<'_>, RequestStream<Req>, ClientStreamingSink<Resp>) in add_client_streaming_handler()
218 let h = move |ctx: RpcContext<'_>, _: Option<MessageReader>| { in add_client_streaming_handler()
235 F: FnMut(RpcContext<'_>, Req, ServerStreamingSink<Resp>) + Send + Clone + 'static, in add_server_streaming_handler()
238 let h = move |ctx: RpcContext<'_>, payload: Option<MessageReader>| { in add_server_streaming_handler()
[all …]
|
| D | lib.rs | 53 RequestStream, RpcContext, ServerStreamingSink, ServerStreamingSinkFailure, UnarySink,
|
| /external/rust/crates/grpcio/src/call/ |
| D | server.rs | 624 pub struct RpcContext<'a> { struct
630 impl<'a> RpcContext<'a> { implementation
631 fn new(ctx: RequestContext, cq: &CompletionQueue) -> RpcContext<'_> { in new()
632 RpcContext { in new()
702 ctx: RpcContext<'_>, in execute_unary()
708 F: FnMut(RpcContext<'_>, P, UnarySink<Q>), in execute_unary()
729 ctx: RpcContext<'_>, in execute_client_streaming()
734 F: FnMut(RpcContext<'_>, RequestStream<P>, ClientStreamingSink<Q>), in execute_client_streaming()
747 ctx: RpcContext<'_>, in execute_server_streaming()
753 F: FnMut(RpcContext<'_>, P, ServerStreamingSink<Q>), in execute_server_streaming()
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | face.py | 147 class RpcContext(six.with_metaclass(abc.ABCMeta)): class
195 class Call(six.with_metaclass(abc.ABCMeta, RpcContext)):
251 class ServicerContext(six.with_metaclass(abc.ABCMeta, RpcContext)):
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | __init__.py | 247 class RpcContext(six.with_metaclass(abc.ABCMeta)): class
298 class Call(six.with_metaclass(abc.ABCMeta, RpcContext)):
948 class ServicerContext(six.with_metaclass(abc.ABCMeta, RpcContext)):
|