aboutsummaryrefslogtreecommitdiff
path: root/tests/after.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/after.rs')
-rw-r--r--tests/after.rs16
1 files changed, 9 insertions, 7 deletions
diff --git a/tests/after.rs b/tests/after.rs
index 20670dc..678a8c6 100644
--- a/tests/after.rs
+++ b/tests/after.rs
@@ -1,5 +1,7 @@
//! Tests for the after channel flavor.
+#![cfg(not(miri))] // TODO: many assertions failed due to Miri is slow
+
use std::sync::atomic::AtomicUsize;
use std::sync::atomic::Ordering;
use std::thread;
@@ -56,20 +58,20 @@ fn len_empty_full() {
let r = after(ms(50));
assert_eq!(r.len(), 0);
- assert_eq!(r.is_empty(), true);
- assert_eq!(r.is_full(), false);
+ assert!(r.is_empty());
+ assert!(!r.is_full());
thread::sleep(ms(100));
assert_eq!(r.len(), 1);
- assert_eq!(r.is_empty(), false);
- assert_eq!(r.is_full(), true);
+ assert!(!r.is_empty());
+ assert!(r.is_full());
r.try_recv().unwrap();
assert_eq!(r.len(), 0);
- assert_eq!(r.is_empty(), true);
- assert_eq!(r.is_full(), false);
+ assert!(r.is_empty());
+ assert!(!r.is_full());
}
#[test]
@@ -211,7 +213,7 @@ fn select() {
break;
}
i => {
- oper.recv(&v[i]).unwrap();
+ oper.recv(v[i]).unwrap();
hits.fetch_add(1, Ordering::SeqCst);
}
}