summaryrefslogtreecommitdiffstats
path: root/tokio-test/tests
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2019-10-21 16:45:13 -0700
committerGitHub <noreply@github.com>2019-10-21 16:45:13 -0700
commitb8cee1a60ad99ef28ec494ae4230e2ef4399fcf9 (patch)
tree5bde8f840d2450397beb3403141802f558ff1147 /tokio-test/tests
parentc9bcbe77b9fa36868cc94cc75426823c7ec205ac (diff)
timer: move `tokio-timer` into `tokio` crate (#1674)
A step towards collapsing Tokio sub crates into a single `tokio` crate (#1318). The `timer` implementation is now provided by the main `tokio` crate. The `timer` functionality may still be excluded from the build by skipping the `timer` feature flag.
Diffstat (limited to 'tokio-test/tests')
-rw-r--r--tokio-test/tests/block_on.rs5
-rw-r--r--tokio-test/tests/clock.rs34
2 files changed, 11 insertions, 28 deletions
diff --git a/tokio-test/tests/block_on.rs b/tokio-test/tests/block_on.rs
index 9b4959e9..6d5f481a 100644
--- a/tokio-test/tests/block_on.rs
+++ b/tokio-test/tests/block_on.rs
@@ -1,8 +1,9 @@
#![warn(rust_2018_idioms)]
-use std::time::{Duration, Instant};
+use tokio::timer::delay;
use tokio_test::block_on;
-use tokio_timer::delay;
+
+use std::time::{Duration, Instant};
#[test]
fn async_block() {
diff --git a/tokio-test/tests/clock.rs b/tokio-test/tests/clock.rs
index 344c599b..abb61e23 100644
--- a/tokio-test/tests/clock.rs
+++ b/tokio-test/tests/clock.rs
@@ -1,12 +1,11 @@
-#![cfg(feature = "broken")]
#![warn(rust_2018_idioms)]
-use futures::Future;
-use std::time::{Duration, Instant};
+use tokio::timer::delay;
use tokio_test::clock::MockClock;
-use tokio_test::task::MockTask;
-use tokio_test::{assert_not_ready, assert_ready};
-use tokio_timer::delay;
+use tokio_test::task;
+use tokio_test::{assert_pending, assert_ready};
+
+use std::time::{Duration, Instant};
#[test]
fn clock() {
@@ -14,30 +13,13 @@ fn clock() {
mock.enter(|handle| {
let deadline = Instant::now() + Duration::from_secs(1);
- let mut delay = delay(deadline);
+ let mut delay = task::spawn(delay(deadline));
- assert_not_ready!(delay.poll());
+ assert_pending!(delay.poll());
handle.advance(Duration::from_secs(2));
- assert_ready!(delay.poll());
- });
-}
-
-#[test]
-fn notify() {
- let deadline = Instant::now() + Duration::from_secs(1);
- let mut mock = MockClock::new();
- let mut task = MockTask::new();
-
- mock.enter(|handle| {
- let mut delay = delay(deadline);
-
- task.enter(|| assert_not_ready!(delay.poll()));
-
- handle.advance(Duration::from_secs(1));
-
- assert!(task.is_notified());
+ assert!(delay.is_woken());
assert_ready!(delay.poll());
});
}