Lines Matching refs:RpcContext

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()
189         F: FnMut(RpcContext<'_>, Req, UnarySink<Resp>) + Send + Clone + 'static,  in add_unary_handler()
192         let h = move |ctx: RpcContext<'_>, payload: Option<MessageReader>| {  in add_unary_handler()
209         F: FnMut(RpcContext<'_>, RequestStream<Req>, ClientStreamingSink<Resp>)  in add_client_streaming_handler()
215         let h = move |ctx: RpcContext<'_>, _: Option<MessageReader>| {  in add_client_streaming_handler()
232         F: FnMut(RpcContext<'_>, Req, ServerStreamingSink<Resp>) + Send + Clone + 'static,  in add_server_streaming_handler()
235         let h = move |ctx: RpcContext<'_>, payload: Option<MessageReader>| {  in add_server_streaming_handler()
252         F: FnMut(RpcContext<'_>, RequestStream<Req>, DuplexSink<Resp>) + Send + Clone + 'static,  in add_duplex_streaming_handler()
255         let h = move |ctx: RpcContext<'_>, _: Option<MessageReader>| {  in add_duplex_streaming_handler()
279     fn check(&mut self, ctx: &RpcContext) -> CheckResult;  in check()