From 9ff1dfe019425c36e010dde918cc7f907af6ebbb Mon Sep 17 00:00:00 2001 From: fufesou Date: Sat, 24 Feb 2024 23:03:56 +0800 Subject: [PATCH] Test. More comment (#7251) Signed-off-by: fufesou --- src/common.rs | 39 ++++++++++++++++++++------------------- 1 file changed, 20 insertions(+), 19 deletions(-) diff --git a/src/common.rs b/src/common.rs index ce3f02da56ce..8bb072906c01 100644 --- a/src/common.rs +++ b/src/common.rs @@ -1483,25 +1483,6 @@ mod tests { ) } - #[tokio::test] - async fn test_tokio_time_interval() { - let mut timer = interval_maker(); - let mut times = Vec::new(); - sleep(Duration::from_secs(3)).await; - loop { - tokio::select! { - _ = timer.tick() => { - times.push(now_time_string()); - if times.len() == 5 { - break; - } - } - } - } - let times2: HashSet = HashSet::from_iter(times.clone()); - assert_eq!(times.len(), times2.len() + 3); - } - // ThrottledInterval tick at the same time as tokio interval, if no sleeps #[allow(non_snake_case)] #[tokio::test] @@ -1531,6 +1512,25 @@ mod tests { assert_eq!(times, tokio_times); } } + + #[tokio::test] + async fn test_tokio_time_interval_sleep() { + let mut timer = interval_maker(); + let mut times = Vec::new(); + sleep(Duration::from_secs(3)).await; + loop { + tokio::select! { + _ = timer.tick() => { + times.push(now_time_string()); + if times.len() == 5 { + break; + } + } + } + } + let times2: HashSet = HashSet::from_iter(times.clone()); + assert_eq!(times.len(), times2.len() + 3); + } // ThrottledInterval tick less times than tokio interval, if there're sleeps #[allow(non_snake_case)] @@ -1553,6 +1553,7 @@ mod tests { } // No mutliple ticks in the `interval` time. // Values in "times" are unique and are less than normal tokio interval. + // See previous test (test_tokio_time_interval_sleep) for comparison. let times2: HashSet = HashSet::from_iter(times.clone()); assert_eq!(times.len(), times2.len()); }