itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make timeout tests slightly more flexible

Browse Source
This commit is contained in:
Alex Crichton 2017-09-10 19:58:35 -07:00
parent 7b94cf307d
commit a4e947fba0
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/interval.rs
View File

@ -19,8 +19,8 @@ fn single() {
drop(env_logger::init()); drop(env_logger::init());
let mut l = t!(Core::new()); let mut l = t!(Core::new());
let dur = Duration::from_millis(10); let dur = Duration::from_millis(10);
let interval = t!(Interval::new(dur, &l.handle()));
let start = Instant::now(); let start = Instant::now();
let interval = t!(Interval::new(dur, &l.handle()));
t!(l.run(interval.take(1).collect())); t!(l.run(interval.take(1).collect()));
assert!(start.elapsed() >= dur); assert!(start.elapsed() >= dur);
} }
@ -30,8 +30,8 @@ fn two_times() {
drop(env_logger::init()); drop(env_logger::init());
let mut l = t!(Core::new()); let mut l = t!(Core::new());
let dur = Duration::from_millis(10); let dur = Duration::from_millis(10);
let interval = t!(Interval::new(dur, &l.handle()));
let start = Instant::now(); let start = Instant::now();
let interval = t!(Interval::new(dur, &l.handle()));
let result = t!(l.run(interval.take(2).collect())); let result = t!(l.run(interval.take(2).collect()));
assert!(start.elapsed() >= dur*2); assert!(start.elapsed() >= dur*2);
assert_eq!(result, vec![(), ()]); assert_eq!(result, vec![(), ()]);

2
tests/timeout.rs
View File

@ -18,8 +18,8 @@ fn smoke() {
drop(env_logger::init()); drop(env_logger::init());
let mut l = t!(Core::new()); let mut l = t!(Core::new());
let dur = Duration::from_millis(10); let dur = Duration::from_millis(10);
let timeout = t!(Timeout::new(dur, &l.handle()));
let start = Instant::now(); let start = Instant::now();
let timeout = t!(Timeout::new(dur, &l.handle()));
t!(l.run(timeout)); t!(l.run(timeout));
assert!(start.elapsed() >= (dur / 2)); assert!(start.elapsed() >= (dur / 2));
} }