| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 18 let (mut c1, mut c2, mut c3, mut c4) = spawn().await.expect("clients"); in smoke_unary()
34 let (mut c1, mut c2, mut c3, mut c4) = spawn().await.expect("clients"); in smoke_client_stream()
52 let (mut c1, mut c2, mut c3, mut c4) = spawn().await.expect("clients"); in smoke_server_stream()
73 let (mut c1, mut c2, mut c3, mut c4) = spawn().await.expect("clients"); in smoke_error()
128 async fn spawn() -> Result<(Client, Client, Client, Client), Error> { in spawn() function
132 drop(tokio::spawn(async move { join!(s1, s2, s3, s4) })); in spawn()
|
| H A D | grpc_web.rs | 24 let server_url = spawn().await; in binary_request()
47 let server_url = spawn().await; in text_request()
68 async fn spawn() -> String { in spawn() function
74 drop(tokio::spawn(async move { in spawn()
|
| /tonic/tests/compression/src/ |
| H A D | compressing_response.rs | 59 tokio::spawn({ in client_enabled_server_enabled()
117 tokio::spawn({ in client_enabled_server_disabled()
158 tokio::spawn({ in client_enabled_server_disabled_multi_encoding()
232 tokio::spawn({ in client_disabled()
284 tokio::spawn(async move { in server_replying_with_unsupported_encoding()
326 tokio::spawn({ in disabling_compression_on_single_response()
384 tokio::spawn({ in disabling_compression_on_response_but_keeping_compression_on_stream()
453 tokio::spawn({ in disabling_compression_on_response_from_client_stream()
|
| H A D | compressing_request.rs | 44 tokio::spawn({ in client_enabled_server_enabled()
108 tokio::spawn({ in client_enabled_server_enabled_multi_encoding()
157 tokio::spawn(async move { in client_enabled_server_disabled()
208 tokio::spawn({ in client_mark_compressed_without_header_server_enabled()
|
| H A D | server_stream.rs | 20 tokio::spawn({ in client_enabled_server_enabled()
85 tokio::spawn({ in client_disabled_server_enabled()
137 tokio::spawn({ in client_enabled_server_disabled()
|
| H A D | client_stream.rs | 44 tokio::spawn({ in client_enabled_server_enabled()
98 tokio::spawn({ in client_disabled_server_enabled()
142 tokio::spawn(async move { in client_enabled_server_disabled()
190 tokio::spawn({ in compressing_response_from_client_stream()
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 93 tokio::spawn(async move { in run_services_in_background()
101 tokio::spawn(async move { in run_services_in_background()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 27 let jh = tokio::spawn(async move { in http2_keepalive_does_not_cause_panics()
57 let jh = tokio::spawn(async move { in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | status.rs | 41 let jh = tokio::spawn(async move { in status_with_details()
99 let jh = tokio::spawn(async move { in status_with_metadata()
170 tokio::spawn(async move { in status_from_server_stream()
240 tokio::spawn(async move { in message_and_then_status_from_server_stream()
|
| H A D | connection.rs | 47 let jh = tokio::spawn(async move { in connect_returns_err_via_call_after_connected()
91 let jh = tokio::spawn(async move { in connect_lazy_reconnects_after_first_failure()
|
| H A D | connect_info.rs | 35 let jh = tokio::spawn(async move { in getting_connect_info()
107 let jh = tokio::spawn(async move { in getting_connect_info()
|
| H A D | extensions.rs | 46 let jh = tokio::spawn(async move { in setting_extension_from_interceptor()
95 let jh = tokio::spawn(async move { in setting_extension_from_tower()
|
| H A D | streams.rs | 31 let jh = tokio::spawn(async move { in status_from_server_stream_with_source()
|
| H A D | user_agent.rs | 31 let jh = tokio::spawn(async move { in writes_user_agent_header()
|
| H A D | interceptor.rs | 31 let jh = tokio::spawn(async move { in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 36 let jh = tokio::spawn(async move { in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 34 let jh = tokio::spawn(async move { in connect_supports_standard_tower_layers()
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 62 tokio::spawn(async move { in server_streaming_echo()
105 tokio::spawn(async move { in bidirectional_streaming_echo()
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 50 tokio::spawn(async move { in main()
107 tokio::spawn(async move { in call()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 69 let jh = tokio::spawn(async move { in make_v1_request()
126 let jh = tokio::spawn(async move { in make_v1alpha_request()
|
| /tonic/examples/src/load_balance/ |
| H A D | server.rs | 42 tokio::spawn(async move { in main()
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | server.rs | 42 tokio::spawn(async move { in main()
|
| /tonic/examples/src/health/ |
| H A D | server.rs | 53 tokio::spawn(twiddle_service_status(health_reporter.clone())); in main()
|
| /tonic/examples/src/mock/ |
| H A D | mock.rs | 24 tokio::spawn(async move { in main()
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 60 let select_task = tokio::spawn(async move { in with_cancellation_handler()
|