| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 13 use tokio::time::timeout;
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()
70 if let Ok(resp) = timeout(tokio::time::Duration::from_secs(10), rx).await { in main()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | retry_info.rs | 1 use std::time;
20 pub retry_delay: Option<time::Duration>,
29 pub const MAX_RETRY_DELAY: time::Duration = time::Duration::new(315_576_000_000, 999_999_999);
34 pub fn new(retry_delay: Option<time::Duration>) -> Self { in new()
87 let duration = time::Duration::try_from(duration).unwrap_or(time::Duration::ZERO); in from()
120 use core::time::Duration;
|
| /tonic/examples/src/routeguide/ |
| H A D | client.rs | 2 use std::time::Duration;
6 use tokio::time;
62 let start = time::Instant::now(); in run_route_chat()
65 let mut interval = time::interval(Duration::from_secs(1)); in run_route_chat()
68 let time = interval.tick().await; in run_route_chat() localVariable
69 let elapsed = time.duration_since(start); in run_route_chat()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connection.rs | 3 use std::time::Duration;
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 | 1 use std::time::Duration;
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 | user_agent.rs | 2 use std::time::Duration;
39 tokio::time::sleep(Duration::from_millis(100)).await; in writes_user_agent_header()
|
| H A D | interceptor.rs | 2 use std::time::Duration;
54 tokio::time::sleep(Duration::from_millis(100)).await; in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 1 use std::time::Duration;
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 | 3 use std::time::Duration;
58 tokio::time::sleep(Duration::from_millis(100)).await; in connect_supports_standard_tower_layers()
|
| H A D | status.rs | 10 use std::time::Duration;
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 | 7 time::Duration,
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 | timeout.rs | 2 use std::{net::SocketAddr, time::Duration};
72 tokio::time::sleep(self.latency).await; in run_service_in_background()
|
| H A D | origin.rs | 6 use std::time::Duration;
47 tokio::time::sleep(Duration::from_millis(100)).await; in writes_origin_header()
|
| H A D | routes_builder.rs | 1 use std::time::Duration;
72 tokio::time::sleep(Duration::from_millis(100)).await; in multiple_service_using_routes_builder()
|
| H A D | connect_info.rs | 2 use std::time::Duration;
43 tokio::time::sleep(Duration::from_millis(100)).await; in getting_connect_info()
|
| /tonic/tonic/benches-disabled/ |
| H A D | README.md | 13 3) As we are not testing tonic-build compile time, the tests reference pre-compiled .rs files in 'b…
23 time: [2.7231 us 2.7588 us 2.7969 us]
26 time: [+16.073% +17.871% +19.980%] (p = 0.00 < 0.05)
|
| /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 | server.rs | 5 use std::time::Duration;
36 tokio::time::sleep(Duration::from_secs(1)).await; in twiddle_service_status()
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 10 use tokio::time::sleep;
11 use tokio::time::Duration;
|
| H A D | client.rs | 4 use tokio::time::{timeout, Duration};
|
| /tonic/examples/src/streaming/ |
| H A D | client.rs | 5 use std::time::Duration;
72 tokio::time::sleep(Duration::from_secs(1)).await; //do not mess server println functions in main()
|
| /tonic/interop/ |
| H A D | Cargo.toml | 25 tokio = {version = "1.0", features = ["rt-multi-thread", "time", "macros"]}
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 8 time::Duration,
10 use tokio::time::Sleep;
60 sleep: timeout_duration.map(tokio::time::sleep), in call()
|
| /tonic/interop/src/ |
| H A D | server.rs | 9 use std::time::Duration;
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()
|