| /tonic/tonic/src/server/ |
| H A D | service.rs | 18 fn call(&mut self, request: Request<R>) -> Self::Future; in call() method 28 fn call(&mut self, request: Request<M1>) -> Self::Future { in call() function 29 Service::call(self, request) in call() 48 fn call(&mut self, request: Request<R>) -> Self::Future; in call() method 60 fn call(&mut self, request: Request<M1>) -> Self::Future { in call() function 61 Service::call(self, request) in call() 77 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call() method 87 fn call(&mut self, request: Request<Streaming<M1>>) -> Self::Future { in call() function 88 Service::call(self, request) in call() 107 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call() method [all …]
|
| H A D | grpc.rs | 247 .call(request) in unary() 290 let response = service.call(request).await; in server_streaming() 321 .call(request) in client_streaming() 354 let response = service.call(request).await; in streaming()
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 13 use crate::call::content_types::is_grpc_web; 14 use crate::call::{Encoding, GrpcWebCall}; 60 fn call(&mut self, req: Request<B>) -> Self::Future { in call() function 247 use crate::call::content_types::*; 323 let res = svc.call(req).await.unwrap(); in without_origin() 342 let res = svc.call(req).await.unwrap(); in only_post_and_options_allowed() 362 let res = svc.call(req).await.unwrap(); in grpc_web_content_types() 407 let res = svc.call(req).await.unwrap(); in h2_is_ok() 421 let res = svc.call(req).await.unwrap(); in h1_is_err() 436 let res = svc.call(req).await.unwrap(); in content_type_variants() [all …]
|
| H A D | lib.rs | 73 pub use call::GrpcWebCall; 78 mod call; module
|
| H A D | client.rs | 12 use crate::call::content_types::GRPC_WEB; 13 use crate::call::GrpcWebCall; 63 fn call(&mut self, mut req: Request<B1>) -> Self::Future { in call() function 75 let fut = self.inner.call(req); in call()
|
| /tonic/tonic-health/proto/ |
| H A D | health.proto | 43 // If the requested service is unknown, the call will fail with status 52 // If the requested service is unknown when the call is received, the 54 // SERVICE_UNKNOWN but will *not* terminate the call. If at some 58 // If the call terminates with status UNIMPLEMENTED, then clients 60 // call. If the call terminates with any other status (including OK), 61 // clients should retry the call with appropriate exponential backoff.
|
| /tonic/tonic/src/client/ |
| H A D | service.rs | 29 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future; in call() method 47 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future { in call() function 48 Service::call(self, request) in call()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 41 fn call(&mut self, mut req: Request<ReqBody>) -> Self::Future { in call() function 45 self.inner.call(req) in call()
|
| H A D | add_origin.rs | 43 fn call(&mut self, req: Request<ReqBody>) -> Self::Future { in call() function 65 let fut = self.inner.call(request); in call()
|
| H A D | connection.rs | 113 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() method 114 self.inner.call(req) in call() 151 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() method 189 fn call(&mut self, req: Uri) -> Self::Future { in call() function 190 let fut = self.connector.call(req); in call()
|
| H A D | connector.rs | 50 fn call(&mut self, uri: Uri) -> Self::Future { in call() function 56 let connect = self.inner.call(uri); in call()
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 34 fn call(&mut self, req: Req) -> Self::Future { in call() function 35 self.inner.call(req) in call()
|
| H A D | interceptor.rs | 43 fn call(&mut self, request: crate::Request<()>) -> Result<crate::Request<()>, Status>; in call() method 50 fn call(&mut self, request: crate::Request<()>) -> Result<crate::Request<()>, Status> { in call() function 129 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call() function 143 .call(crate::Request::from_parts(metadata, extensions, ())) in call() 149 ResponseFuture::future(self.inner.call(req)) in call()
|
| H A D | recover_error.rs | 65 fn call(&mut self, req: Req) -> Self::Future { in call() function 67 inner: self.inner.call(req), in call()
|
| H A D | router.rs | 157 fn call(&mut self, req: Request<B>) -> Self::Future { in call() function 158 RoutesFuture(self.router.call(req.map(axum::body::Body::new))) in call()
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 70 fn call(&mut self, req: Request<Body>) -> Self::Future { in call() method 77 let response = inner.call(req).await?; in call()
|
| H A D | server.rs | 97 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call() function 104 let response = inner.call(req).await?; in call()
|
| /tonic/interop/src/ |
| H A D | server.rs | 196 fn call(&mut self, req: http::Request<Body>) -> Self::Future { in call() function 206 let call = self.inner.call(req); in call() localVariable 209 let mut res = call.await?; in call()
|
| /tonic/tests/compression/src/ |
| H A D | bidirectional_stream.rs | 34 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled() method 55 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | origin.rs | 98 fn call(&mut self, req: Request<tonic::body::Body>) -> Self::Future { in call() function 100 let fut = self.inner.call(req); in call()
|
| H A D | extensions.rs | 142 fn call(&mut self, mut req: http::Request<Body>) -> Self::Future { in call() function 149 let response = inner.call(req).await?; in call()
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 119 fn call(&mut self, _: R) -> Self::Future { in call() method 130 fn call(&mut self, req: http::Request<HyperBody>) -> Self::Future { in call() method 138 fn call( in call() method
|
| /tonic/tonic-web/ |
| H A D | README.md | 8 The easiest way to get started, is to call the function with your tonic service
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 46 fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, Status> { in call() method
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 62 fn call(&mut self, mut req: http::Request<ReqBody>) -> Self::Future { in call() function 73 self.inner.call(req) in call()
|