| /tonic/tests/integration_tests/tests/ |
| H A D | status.rs | 20 struct Svc; in status_with_details() struct
23 impl test_server::Test for Svc { in status_with_details() implementation
33 let svc = test_server::TestServer::new(Svc); in status_with_details()
78 struct Svc; in status_with_metadata() struct
81 impl test_server::Test for Svc { in status_with_metadata() implementation
91 let svc = test_server::TestServer::new(Svc); in status_with_metadata()
146 struct Svc; in status_from_server_stream() struct
149 impl test_stream_server::TestStream for Svc { in status_from_server_stream() implementation
164 let svc = test_stream_server::TestStreamServer::new(Svc); in status_from_server_stream()
216 struct Svc; in message_and_then_status_from_server_stream() struct
[all …]
|
| H A D | connect_info.rs | 14 struct Svc; in getting_connect_info() struct
17 impl test_server::Test for Svc { in getting_connect_info() implementation
27 let svc = test_server::TestServer::new(Svc); in getting_connect_info()
78 struct Svc {} struct
81 impl test_server::Test for Svc { implementation
104 let service = test_server::TestServer::new(Svc {}); in getting_connect_info()
|
| H A D | extensions.rs | 23 struct Svc; in setting_extension_from_interceptor() struct
26 impl test_server::Test for Svc { in setting_extension_from_interceptor() implementation
35 let svc = test_server::TestServer::with_interceptor(Svc, |mut req: Request<()>| { in setting_extension_from_interceptor()
73 struct Svc; in setting_extension_from_tower() struct
76 impl test_server::Test for Svc { in setting_extension_from_tower() implementation
86 inner: test_server::TestServer::new(Svc), in setting_extension_from_tower()
|
| H A D | streams.rs | 11 struct Svc; in status_from_server_stream_with_source() struct
14 impl test_stream_server::TestStream for Svc { in status_from_server_stream_with_source() implementation
27 let svc = test_stream_server::TestStreamServer::new(Svc); in status_from_server_stream_with_source()
|
| H A D | http2_keep_alive.rs | 9 struct Svc; struct
12 impl test_server::Test for Svc { implementation
20 let svc = test_server::TestServer::new(Svc {}); in http2_keepalive_does_not_cause_panics()
50 let svc = test_server::TestServer::new(Svc {}); in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | user_agent.rs | 11 struct Svc; in writes_user_agent_header() struct
14 impl test_server::Test for Svc { in writes_user_agent_header() implementation
23 let svc = test_server::TestServer::new(Svc); in writes_user_agent_header()
|
| H A D | interceptor.rs | 13 struct Svc; in interceptor_retrieves_grpc_method() struct
16 impl Test for Svc { in interceptor_retrieves_grpc_method() implementation
22 let svc = test_server::TestServer::new(Svc); in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 14 struct Svc; in test_http_max_header_list_size_and_long_errors() struct
24 impl test_server::Test for Svc { in test_http_max_header_list_size_and_long_errors() implementation
30 let svc = test_server::TestServer::new(Svc); in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 14 struct Svc; in connect_supports_standard_tower_layers() struct
17 impl test_server::Test for Svc { in connect_supports_standard_tower_layers() implementation
27 let svc = test_server::TestServer::new(Svc); in connect_supports_standard_tower_layers()
|
| H A D | complex_tower_middleware.rs | 15 struct Svc; in complex_tower_layers_work() struct
18 impl test_server::Test for Svc { in complex_tower_layers_work() implementation
24 let svc = test_server::TestServer::new(Svc); in complex_tower_layers_work()
|
| H A D | connection.rs | 10 struct Svc(Arc<Mutex<Option<oneshot::Sender<()>>>>); struct
13 impl test_server::Test for Svc { implementation
41 let svc = test_server::TestServer::new(Svc(sender)); in connect_returns_err_via_call_after_connected()
76 let svc = test_server::TestServer::new(Svc(sender)); in connect_lazy_reconnects_after_first_failure()
|
| H A D | timeout.rs | 65 struct Svc { in run_service_in_background() struct
70 impl test_server::Test for Svc { in run_service_in_background() implementation
77 let svc = test_server::TestServer::new(Svc { latency }); in run_service_in_background()
|
| H A D | max_message_size.rs | 123 struct Svc; in response_stream_limit() struct
126 impl test1_server::Test1 for Svc { in response_stream_limit() implementation
147 let svc = test1_server::Test1Server::new(Svc); in response_stream_limit()
280 struct Svc(Vec<u8>); in max_message_run() struct
283 impl test1_server::Test1 for Svc { in max_message_run() implementation
301 let svc = test1_server::Test1Server::new(Svc(server_blob)); in max_message_run()
|
| H A D | origin.rs | 18 struct Svc; in writes_origin_header() struct
21 impl test_server::Test for Svc { in writes_origin_header() implementation
30 let svc = test_server::TestServer::new(Svc); in writes_origin_header()
|
| /tonic/tests/default_stubs/src/ |
| H A D | lib.rs | 13 struct Svc; struct
16 impl test_server::Test for Svc { implementation
45 impl test_default_server::TestDefault for Svc { implementation
|
| H A D | test_defaults.rs | 84 let svc = test_server::TestServer::new(Svc {}); in run_services_in_background()
85 let svc_default_stubs = test_default_server::TestDefaultServer::new(Svc {}); in run_services_in_background()
|
| /tonic/tests/use_arc_self/src/ |
| H A D | lib.rs | 10 struct Svc; struct
13 impl test_server::Test for Svc { implementation
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 256 struct Svc; struct
272 impl NamedService for Svc { implementation
302 let mut svc = enable(Svc); in default_cors_config()
318 let mut svc = enable(Svc); in without_origin()
330 let mut svc = enable(Svc); in only_post_and_options_allowed()
355 let mut svc = enable(Svc); in grpc_web_content_types()
384 let mut svc = enable(Svc); in valid_grpc_web_preflight()
404 let mut svc = enable(Svc); in h2_is_ok()
414 let mut svc = enable(Svc); in h1_is_err()
427 let mut svc = enable(Svc); in content_type_variants()
[all …]
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 53 struct Svc; struct
58 UserAgent::new(Svc, None).user_agent, in sets_default_if_no_custom_user_agent()
66 UserAgent::new(Svc, Some(HeaderValue::from_static("Greeter 1.1"))).user_agent, in prepends_custom_user_agent_to_default()
|
| /tonic/tests/compression/src/ |
| H A D | lib.rs | 31 struct Svc { struct
37 impl Svc { implementation
48 impl test_server::Test for Svc { implementation
|
| H A D | compressing_response.rs | 55 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled()
113 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
154 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled_multi_encoding()
228 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_disabled()
275 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in server_replying_with_unsupported_encoding()
319 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_single_response()
377 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_response_but_keeping_compression_on_stream()
446 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_response_from_client_stream()
|
| H A D | compressing_request.rs | 16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled()
93 let svc = test_server::TestServer::new(Svc::default()) in client_enabled_server_enabled_multi_encoding()
155 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
206 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_mark_compressed_without_header_server_enabled()
|
| H A D | server_stream.rs | 16 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled()
81 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_disabled_server_enabled()
133 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
|
| H A D | client_stream.rs | 16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled()
89 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_disabled_server_enabled()
140 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
186 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in compressing_response_from_client_stream()
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 14 pub struct Svc; struct
17 impl Test for Svc { implementation
|