| /tonic/examples/src/tower/ |
| H A D | server.rs | 43 let layer = tower::ServiceBuilder::new() in main() localVariable
45 .layer(MyMiddlewareLayer::default()) in main()
47 .layer(tonic::service::InterceptorLayer::new(intercept)) in main()
52 .layer(layer) in main()
71 fn layer(&self, service: S) -> Self::Service { in layer() method
|
| H A D | client.rs | 18 .layer(tonic::service::InterceptorLayer::new(intercept)) in main()
|
| /tonic/tests/compression/src/ |
| H A D | compressing_response.rs | 63 .layer( in client_enabled_server_enabled()
69 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
122 .layer( in client_enabled_server_disabled()
124 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_disabled()
163 .layer( in client_enabled_server_disabled_multi_encoding()
236 .layer( in client_disabled()
238 .layer(layer_fn(AssertCorrectAcceptEncoding)) in client_disabled()
286 .layer( in server_replying_with_unsupported_encoding()
330 .layer( in disabling_compression_on_single_response()
388 .layer( in disabling_compression_on_response_but_keeping_compression_on_stream()
[all …]
|
| H A D | server_stream.rs | 24 .layer( in client_enabled_server_enabled()
26 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
89 .layer( in client_disabled_server_enabled()
91 .layer(MapResponseBodyLayer::new(move |body| { in client_disabled_server_enabled()
141 .layer( in client_enabled_server_disabled()
143 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_disabled()
|
| H A D | compressing_request.rs | 48 .layer( in client_enabled_server_enabled()
50 .layer( in client_enabled_server_enabled()
55 .layer(measure_request_body_size_layer(request_bytes_counter)) in client_enabled_server_enabled()
112 .layer( in client_enabled_server_enabled_multi_encoding()
114 .layer( in client_enabled_server_enabled_multi_encoding()
117 .layer(measure_request_body_size_layer(request_bytes_counter)) in client_enabled_server_enabled_multi_encoding()
|
| H A D | client_stream.rs | 48 .layer( in client_enabled_server_enabled()
53 .layer(measure_request_body_size_layer( in client_enabled_server_enabled()
102 .layer( in client_disabled_server_enabled()
105 .layer(measure_request_body_size_layer( in client_disabled_server_enabled()
194 .layer( in compressing_response_from_client_stream()
196 .layer(MapResponseBodyLayer::new(move |body| { in compressing_response_from_client_stream()
|
| H A D | bidirectional_stream.rs | 52 .layer( in client_enabled_server_enabled()
57 .layer(measure_request_body_size_layer( in client_enabled_server_enabled()
60 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
|
| H A D | lib.rs | 18 use tower::{layer::layer_fn, service_fn, Service, ServiceBuilder};
|
| /tonic/tonic-web/src/ |
| H A D | lib.rs | 75 pub use layer::GrpcWebLayer;
80 mod layer; module
|
| H A D | layer.rs | 21 fn layer(&self, inner: S) -> Self::Service { in layer() method
|
| H A D | client.rs | 31 fn layer(&self, inner: S) -> Self::Service { in layer() method
|
| H A D | service.rs | 284 .layer(service) in enable()
310 let mut svc = crate::GrpcWebLayer::new().layer(Svc); in web_layer()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 11 use tower::{layer::Layer, BoxError, Service};
27 .layer(MyServiceLayer::new()) in complex_tower_layers_work()
46 fn layer(&self, inner: S) -> Self::Service { in layer() method
|
| H A D | client_layer.rs | 50 .layer(SetRequestHeaderLayer::overriding( in connect_supports_standard_tower_layers()
54 .layer(TraceLayer::new_for_grpc()) in connect_supports_standard_tower_layers()
|
| H A D | origin.rs | 40 .layer(OriginLayer {}) in writes_origin_header()
74 fn layer(&self, inner: S) -> Self::Service { in layer() method
|
| /tonic/examples/src/grpc-web/ |
| H A D | server.rs | 36 .layer(tower_http::cors::CorsLayer::new()) in main()
37 .layer(tonic_web::GrpcWebLayer::new()) in main()
|
| H A D | client.rs | 15 .layer(GrpcWebClientLayer::new()) in main()
|
| /tonic/tonic-web/ |
| H A D | README.md | 19 .layer(GrpcWebLayer::new())
|
| H A D | Cargo.toml | 27 tower-layer = "0.3"
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 53 inner: self.layer(service), in named_layer()
|
| H A D | recover_error.rs | 33 fn layer(&self, inner: S) -> Self::Service { in layer() method
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 68 layer::util::{Identity, Stack},
69 layer::Layer,
514 pub fn layer<NewLayer>(self, new_layer: NewLayer) -> Server<Stack<NewLayer, L>> { in layer() method
516 service_builder: self.service_builder.layer(new_layer), in layer()
1091 .layer(RecoverErrorLayer::new()) in call()
1097 .layer(BoxCloneService::layer()) in call()
1098 .layer(ConnectInfoLayer::new(conn_info.clone())) in call()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 16 layer::Layer,
76 inner: BoxService::new(stack.layer(conn)), in new()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 77 .layer(GrpcWebLayer::new()) in spawn()
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 29 fn layer(&self, inner: S) -> Self::Service { in layer() function
|