| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 76 type Service = InterceptedService<S, I>;
79 InterceptedService::new(service, self.interceptor.clone()) in layer()
87 pub struct InterceptedService<S, I> { struct
92 impl<S, I> InterceptedService<S, I> { implementation
103 impl<S, I> fmt::Debug for InterceptedService<S, I> implementation
115 impl<S, I, ReqBody, ResBody> Service<http::Request<ReqBody>> for InterceptedService<S, I> implementation
157 impl<S, I> crate::server::NamedService for InterceptedService<S, I> implementation
288 let svc = InterceptedService::new(svc, |request: crate::Request<()>| { in doesnt_remove_headers_from_requests()
317 let svc = InterceptedService::new(svc, |_: crate::Request<()>| { in handles_intercepted_status_as_response()
337 let svc = InterceptedService::new(svc, Ok); in doesnt_change_http_method()
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 4 codegen::InterceptedService,
57 let client: GreeterClient<InterceptedService<Channel, MyInterceptor>> = in using_named_interceptor()
72 InterceptedService<Channel, fn(tonic::Request<()>) -> Result<tonic::Request<()>, Status>>, in using_function_pointer_interceptro()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | extensions.rs | 85 let svc = InterceptedService { in setting_extension_from_tower()
121 struct InterceptedService<S> { struct
125 impl<S> Service<http::Request<Body>> for InterceptedService<S> argument
155 impl<S: NamedService> NamedService for InterceptedService<S> { implementation
|
| /tonic/tonic/src/ |
| H A D | codegen.rs | 14 pub use crate::service::interceptor::InterceptedService;
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 91 ) -> HealthClient<InterceptedService<T, F>> in with_interceptor()
105 HealthClient::new(InterceptedService::new(inner, interceptor)) in with_interceptor()
277 ) -> InterceptedService<Self, F> in with_interceptor()
281 InterceptedService::new(Self::new(inner), interceptor) in with_interceptor()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
194 ServerReflectionClient::new(InterceptedService::new(inner, interceptor)) in with_interceptor()
318 ) -> InterceptedService<Self, F> in with_interceptor()
322 InterceptedService::new(Self::new(inner), interceptor) in with_interceptor()
|
| H A D | grpc_reflection_v1alpha.rs | 180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
194 ServerReflectionClient::new(InterceptedService::new(inner, interceptor)) in with_interceptor()
318 ) -> InterceptedService<Self, F> in with_interceptor()
322 InterceptedService::new(Self::new(inner), interceptor) in with_interceptor()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 85 … pub fn with_interceptor<F>(inner: T, interceptor: F) -> #service_ident<InterceptedService<T, F>> in generate_internal()
95 #service_ident::new(InterceptedService::new(inner, interceptor)) in generate_internal()
|
| H A D | server.rs | 137 pub fn with_interceptor<F>(inner: T, interceptor: F) -> InterceptedService<Self, F> in generate_internal()
141 InterceptedService::new(Self::new(inner), interceptor) in generate_internal()
|