| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 550 <<L as Layer<S>>::Service as Service<Request<Body>>>::Future: Send, in serve()
551 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve()
570 <<L as Layer<S>>::Service as Service<Request<Body>>>::Future: Send, in serve_with_shutdown()
571 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve_with_shutdown()
592 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve_with_incoming()
615 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve_with_incoming_shutdown()
637 <<L as Layer<S>>::Service as Service<Request<Body>>>::Error: in serve_internal()
882 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: in serve()
905 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: in serve_with_shutdown()
933 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: in serve_with_incoming()
[all …]
|
| /tonic/tonic/src/server/ |
| H A D | service.rs | 4 use tower_service::Service;
23 T: Service<Request<M1>, Response = Response<M2>, Error = crate::Status>,
29 Service::call(self, request) in call()
53 T: Service<Request<M1>, Response = Response<S>, Error = crate::Status>,
61 Service::call(self, request) in call()
82 T: Service<Request<Streaming<M1>>, Response = Response<M2>, Error = crate::Status>,
88 Service::call(self, request) in call()
112 T: Service<Request<Streaming<M1>>, Response = Response<S>, Error = crate::Status>,
120 Service::call(self, request) in call()
|
| /tonic/tonic/src/client/ |
| H A D | service.rs | 4 use tower_service::Service;
34 T: Service<http::Request<ReqBody>, Response = http::Response<ResBody>>,
44 Service::poll_ready(self, cx) in poll_ready()
48 Service::call(self, request) in call()
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 7 use tower_service::Service;
22 impl<Req, S, T> Service<Req> for Layered<S, T>
24 S: Service<Req>,
42 fn named_layer<S>(&self, service: S) -> Layered<L::Service, S> in named_layer() argument
48 fn named_layer<S>(&self, service: S) -> Layered<<L>::Service, S> in named_layer() argument
|
| H A D | recover_error.rs | 13 use tower_service::Service;
31 type Service = RecoverError<S>; typedef
33 fn layer(&self, inner: S) -> Self::Service { in layer() argument
52 impl<S, Req, ResBody> Service<Req> for RecoverError<S>
54 S: Service<Req, Response = Response<ResBody>>,
|
| H A D | router.rs | 10 use tower::{Service, ServiceExt};
28 S: Service<Request<Body>, Error = Infallible> in add_service()
60 S: Service<Request<Body>, Error = Infallible> in new()
80 S: Service<Request<Body>, Error = Infallible> in add_service()
143 impl<B> Service<Request<B>> for Routes impl
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 11 use tower::{layer::Layer, BoxError, Service};
44 type Service = MyService<S>; typedef
46 fn layer(&self, inner: S) -> Self::Service { in layer() argument
56 impl<S, R, ResBody> Service<R> for MyService<S>
58 S: Service<R, Response = http::Response<ResBody>>,
|
| H A D | origin.rs | 14 use tower::Service;
72 type Service = OriginService<S>; typedef
74 fn layer(&self, inner: S) -> Self::Service { in layer() argument
84 impl<T> Service<Request<tonic::body::Body>> for OriginService<T> impl
86 T: Service<Request<tonic::body::Body>>,
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | reconnect.rs | 9 use tower_service::Service;
14 M: Service<Target>,
34 M: Service<Target>,
49 impl<M, Target, S, Request> Service<Request> for Reconnect<M, Target>
51 M: Service<Target, Response = S>,
52 S: Service<Request>,
56 <M as tower_service::Service<Target>>::Error: Into<crate::BoxError>,
158 M: Service<Target> + fmt::Debug,
162 <M as tower_service::Service<Target>>::Error: Into<crate::BoxError>,
|
| H A D | connection.rs | 21 use tower_service::Service;
30 C: Service<Uri> + Send + 'static, in new()
85 C: Service<Uri> + Send + 'static, in connect()
95 C: Service<Uri> + Send + 'static, in lazy()
104 impl Service<Request<Body>> for Connection { impl
110 Service::poll_ready(&mut self.inner, cx).map_err(Into::into) in poll_ready()
142 impl tower::Service<Request<Body>> for SendRequest {
174 impl<C> tower::Service<Uri> for MakeSendRequestService<C>
176 C: Service<Uri> + Send + 'static,
|
| H A D | user_agent.rs | 3 use tower_service::Service;
29 impl<T, ReqBody> Service<Request<ReqBody>> for UserAgent<T> impl
31 T: Service<Request<ReqBody>>,
|
| H A D | add_origin.rs | 6 use tower_service::Service;
29 impl<T, ReqBody> Service<Request<ReqBody>> for AddOrigin<T> impl
31 T: Service<Request<ReqBody>>,
|
| H A D | connector.rs | 15 use tower_service::Service;
33 impl<C> Service<Uri> for Connector<C>
35 C: Service<Uri>,
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 9 use tower_service::Service;
29 type Service = GrpcWebClientService<S>; typedef
31 fn layer(&self, inner: S) -> Self::Service { in layer() argument
51 impl<S, B1, B2> Service<Request<B1>> for GrpcWebClientService<S> impl
53 S: Service<Request<GrpcWebCall<B1>>, Response = Response<B2>>,
|
| H A D | layer.rs | 19 type Service = GrpcWebService<S>; typedef
21 fn layer(&self, inner: S) -> Self::Service { in layer() argument
|
| /tonic/examples/src/tower/ |
| H A D | server.rs | 6 use tower::{Layer, Service};
69 type Service = MyMiddleware<S>; typedef
71 fn layer(&self, service: S) -> Self::Service { in layer() argument
83 impl<S, ReqBody, ResBody> Service<http::Request<ReqBody>> for MyMiddleware<S> impl
85 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>> + Clone + Send + 'static,
|
| H A D | client.rs | 48 use tower::Service;
60 impl Service<Request<Body>> for AuthSvc { impl
|
| /tonic/tonic-build/src/ |
| H A D | code_gen.rs | 5 use crate::{Attributes, Service};
78 pub fn generate_client(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_client() argument
94 pub fn generate_server(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_server() argument
|
| H A D | manual.rs | 103 pub fn build(self) -> Service { in build() argument
104 Service { in build()
115 pub struct Service { struct
126 impl Service { implementation
133 impl crate::Service for Service { implementation
362 fn generate(&mut self, service: &Service) { in generate() argument
478 pub fn compile(self, services: &[Service]) { in compile() argument
|
| H A D | client.rs | 3 use super::{Attributes, Method, Service};
11 pub(crate) fn generate_internal<T: Service>( in generate_internal()
89 T: tonic::codegen::Service< in generate_internal()
93 …<T as tonic::codegen::Service<http::Request<tonic::body::Body>>>::Error: Into<StdError> + std::mar… in generate_internal()
167 fn generate_methods<T: Service>( in generate_methods()
221 fn generate_unary<T: Service>( in generate_unary()
252 fn generate_server_streaming<T: Service>( in generate_server_streaming()
283 fn generate_client_streaming<T: Service>( in generate_client_streaming()
314 fn generate_streaming<T: Service>( in generate_streaming()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 35 Service,
152 C: Service<Uri> + Send + 'static, in new()
173 C: Service<Uri> + Send + 'static, in connect()
192 D: Discover<Service = Connection> + Unpin + Send + 'static, in balance() argument
207 impl Service<http::Request<Body>> for Channel { impl
213 Service::poll_ready(&mut self.svc, cx).map_err(super::Error::from_source) in poll_ready()
217 let inner = Service::call(&mut self.svc, request); in call()
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 10 use tower_service::Service;
27 type Service = ConnectInfo<S, T>; typedef
29 fn layer(&self, inner: S) -> Self::Service { in layer() argument
49 impl<S, IO, ReqBody> Service<http::Request<ReqBody>> for ConnectInfo<S, ServerIoConnectInfo<IO>> impl
51 S: Service<http::Request<ReqBody>>,
|
| /tonic/tests/service_named_service/proto/ |
| H A D | foo.proto | 5 service Service { service
|
| /tonic/tests/wellknown-compiled/proto/ |
| H A D | test.proto | 9 service Service { service
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 73 use tower::{Service, ServiceExt};
82 impl<S> Service<Request<Incoming>> for H2c<S> impl
84 S: Service<Request<Body>, Response = Response<Body>> + Clone + Send + 'static,
|