| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 26 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
31 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
36 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
42 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
48 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
55 tokio::time::sleep(tokio::time::Duration::from_secs(5)).await; in main()
64 tokio::time::sleep(tokio::time::Duration::from_millis(500)).await; in main()
|
| /tonic/interop/ |
| H A D | test.sh | 58 sleep 1
73 sleep 1
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 60 sleep: timeout_duration.map(tokio::time::sleep), in call()
70 sleep: Option<Sleep>, field
87 if let Some(sleep) = this.sleep.as_pin_mut() { in poll()
88 ready!(sleep.poll(cx)); in poll()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connection.rs | 55 tokio::time::sleep(Duration::from_millis(100)).await; in connect_returns_err_via_call_after_connected()
62 tokio::time::sleep(Duration::from_millis(100)).await; in connect_returns_err_via_call_after_connected()
105 tokio::time::sleep(Duration::from_millis(100)).await; in connect_lazy_reconnects_after_first_failure()
109 tokio::time::sleep(Duration::from_millis(100)).await; in connect_lazy_reconnects_after_first_failure()
|
| H A D | http2_keep_alive.rs | 36 tokio::time::sleep(Duration::from_millis(100)).await; in http2_keepalive_does_not_cause_panics()
66 tokio::time::sleep(Duration::from_millis(100)).await; in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | status.rs | 49 tokio::time::sleep(Duration::from_millis(100)).await; in status_with_details()
107 tokio::time::sleep(Duration::from_millis(100)).await; in status_with_metadata()
178 tokio::time::sleep(Duration::from_millis(100)).await; in status_from_server_stream()
248 tokio::time::sleep(Duration::from_millis(100)).await; in message_and_then_status_from_server_stream()
|
| H A D | extensions.rs | 54 tokio::time::sleep(Duration::from_millis(100)).await; in setting_extension_from_interceptor()
103 tokio::time::sleep(Duration::from_millis(100)).await; in setting_extension_from_tower()
|
| H A D | user_agent.rs | 39 tokio::time::sleep(Duration::from_millis(100)).await; in writes_user_agent_header()
|
| H A D | interceptor.rs | 54 tokio::time::sleep(Duration::from_millis(100)).await; in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 49 tokio::time::sleep(Duration::from_millis(100)).await; in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 58 tokio::time::sleep(Duration::from_millis(100)).await; in connect_supports_standard_tower_layers()
|
| H A D | timeout.rs | 72 tokio::time::sleep(self.latency).await; in run_service_in_background()
|
| H A D | origin.rs | 47 tokio::time::sleep(Duration::from_millis(100)).await; in writes_origin_header()
|
| H A D | routes_builder.rs | 72 tokio::time::sleep(Duration::from_millis(100)).await; in multiple_service_using_routes_builder()
|
| H A D | connect_info.rs | 43 tokio::time::sleep(Duration::from_millis(100)).await; in getting_connect_info()
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 10 use tokio::time::sleep;
31 sleep(Duration::from_secs(10)).await; in say_hello()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 82 tokio::time::sleep(std::time::Duration::from_millis(100)).await; in make_v1_request()
139 tokio::time::sleep(std::time::Duration::from_millis(100)).await; in make_v1alpha_request()
|
| H A D | server.rs | 118 tokio::time::sleep(std::time::Duration::from_millis(100)).await; in make_test_reflection_request()
|
| /tonic/examples/src/health/ |
| H A D | README.md | 12 sleep 1
|
| H A D | server.rs | 36 tokio::time::sleep(Duration::from_secs(1)).await; in twiddle_service_status()
|
| /tonic/examples/src/streaming/ |
| H A D | client.rs | 72 tokio::time::sleep(Duration::from_secs(1)).await; //do not mess server println functions in main()
|
| /tonic/interop/src/ |
| H A D | server.rs | 74 tokio::time::sleep(Duration::from_micros(param.interval_us as u64)).await; in streaming_output_call()
129 tokio::time::sleep(Duration::from_micros(param.interval_us as u64)).await; in full_duplex_call()
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 65 use tokio::time::sleep;
791 let sleep = sleep_or_pending(max_connection_age); in serve_connection() localVariable
792 tokio::pin!(sleep); in serve_connection()
802 _ = &mut sleep => { in serve_connection()
804 sleep.set(sleep_or_pending(None)); in serve_connection()
820 Some(wait) => sleep(wait).await, in sleep_or_pending()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 134 tokio::time::sleep(Duration::from_millis(30)).await; in spawn()
|