summaryrefslogtreecommitdiffstats
path: root/vendor/tokio/tests/time_rt.rs
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/tokio/tests/time_rt.rs')
-rw-r--r--vendor/tokio/tests/time_rt.rs11
1 files changed, 6 insertions, 5 deletions
diff --git a/vendor/tokio/tests/time_rt.rs b/vendor/tokio/tests/time_rt.rs
index 077534352..20f9e181b 100644
--- a/vendor/tokio/tests/time_rt.rs
+++ b/vendor/tokio/tests/time_rt.rs
@@ -5,6 +5,7 @@ use tokio::time::*;
use std::sync::mpsc;
+#[cfg(all(feature = "rt-multi-thread", not(tokio_wasi)))] // Wasi doesn't support threads
#[test]
fn timer_with_threaded_runtime() {
use tokio::runtime::Runtime;
@@ -13,7 +14,7 @@ fn timer_with_threaded_runtime() {
let (tx, rx) = mpsc::channel();
rt.spawn(async move {
- let when = Instant::now() + Duration::from_millis(100);
+ let when = Instant::now() + Duration::from_millis(10);
sleep_until(when).await;
assert!(Instant::now() >= when);
@@ -25,14 +26,14 @@ fn timer_with_threaded_runtime() {
}
#[test]
-fn timer_with_basic_scheduler() {
+fn timer_with_current_thread_scheduler() {
use tokio::runtime::Builder;
let rt = Builder::new_current_thread().enable_all().build().unwrap();
let (tx, rx) = mpsc::channel();
rt.block_on(async move {
- let when = Instant::now() + Duration::from_millis(100);
+ let when = Instant::now() + Duration::from_millis(10);
sleep_until(when).await;
assert!(Instant::now() >= when);
@@ -67,7 +68,7 @@ async fn starving() {
}
}
- let when = Instant::now() + Duration::from_millis(20);
+ let when = Instant::now() + Duration::from_millis(10);
let starve = Starve(Box::pin(sleep_until(when)), 0);
starve.await;
@@ -81,7 +82,7 @@ async fn timeout_value() {
let (_tx, rx) = oneshot::channel::<()>();
let now = Instant::now();
- let dur = Duration::from_millis(20);
+ let dur = Duration::from_millis(10);
let res = timeout(dur, rx).await;
assert!(res.is_err());