diff options
Diffstat (limited to 'tests/stream_timeout.rs')
-rw-r--r-- | tests/stream_timeout.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/tests/stream_timeout.rs b/tests/stream_timeout.rs index f65c835..a787bba 100644 --- a/tests/stream_timeout.rs +++ b/tests/stream_timeout.rs @@ -1,14 +1,14 @@ #![cfg(feature = "full")] use tokio::stream::{self, StreamExt}; -use tokio::time::{self, delay_for, Duration}; +use tokio::time::{self, sleep, Duration}; use tokio_test::*; use futures::StreamExt as _; -async fn maybe_delay(idx: i32) -> i32 { +async fn maybe_sleep(idx: i32) -> i32 { if idx % 2 == 0 { - delay_for(ms(200)).await; + sleep(ms(200)).await; } idx } @@ -26,7 +26,7 @@ async fn basic_usage() { // // [Ok(1), Err(Elapsed), Ok(2), Ok(3), Err(Elapsed), Ok(4)] - let stream = stream::iter(1..=4).then(maybe_delay).timeout(ms(100)); + let stream = stream::iter(1..=4).then(maybe_sleep).timeout(ms(100)); let mut stream = task::spawn(stream); // First item completes immediately @@ -68,7 +68,7 @@ async fn basic_usage() { async fn return_elapsed_errors_only_once() { time::pause(); - let stream = stream::iter(1..=3).then(maybe_delay).timeout(ms(50)); + let stream = stream::iter(1..=3).then(maybe_sleep).timeout(ms(50)); let mut stream = task::spawn(stream); // First item completes immediately @@ -97,7 +97,7 @@ async fn return_elapsed_errors_only_once() { #[tokio::test] async fn no_timeouts() { let stream = stream::iter(vec![1, 3, 5]) - .then(maybe_delay) + .then(maybe_sleep) .timeout(ms(100)); let mut stream = task::spawn(stream); |