aboutsummaryrefslogtreecommitdiff
path: root/vendor/flume/tests/never.rs
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/flume/tests/never.rs')
-rw-r--r--vendor/flume/tests/never.rs99
1 files changed, 0 insertions, 99 deletions
diff --git a/vendor/flume/tests/never.rs b/vendor/flume/tests/never.rs
deleted file mode 100644
index 676903f..0000000
--- a/vendor/flume/tests/never.rs
+++ /dev/null
@@ -1,99 +0,0 @@
-// //! Tests for the never channel flavor.
-
-// #[macro_use]
-// extern crate crossbeam_channel;
-// extern crate rand;
-
-// use std::thread;
-// use std::time::{Duration, Instant};
-
-// use crossbeam_channel::{never, tick, unbounded};
-
-// fn ms(ms: u64) -> Duration {
-// Duration::from_millis(ms)
-// }
-
-// #[test]
-// fn smoke() {
-// select! {
-// recv(never::<i32>()) -> _ => panic!(),
-// default => {}
-// }
-// }
-
-// #[test]
-// fn optional() {
-// let (s, r) = unbounded::<i32>();
-// s.send(1).unwrap();
-// s.send(2).unwrap();
-
-// let mut r = Some(&r);
-// select! {
-// recv(r.unwrap_or(&never())) -> _ => {}
-// default => panic!(),
-// }
-
-// r = None;
-// select! {
-// recv(r.unwrap_or(&never())) -> _ => panic!(),
-// default => {}
-// }
-// }
-
-// #[test]
-// fn tick_n() {
-// let mut r = tick(ms(100));
-// let mut step = 0;
-
-// loop {
-// select! {
-// recv(r) -> _ => step += 1,
-// default(ms(500)) => break,
-// }
-
-// if step == 10 {
-// r = never();
-// }
-// }
-
-// assert_eq!(step, 10);
-// }
-
-// #[test]
-// fn capacity() {
-// let r = never::<i32>();
-// assert_eq!(r.capacity(), Some(0));
-// }
-
-// #[test]
-// fn len_empty_full() {
-// let r = never::<i32>();
-// assert_eq!(r.len(), 0);
-// assert_eq!(r.is_empty(), true);
-// assert_eq!(r.is_full(), true);
-// }
-
-// #[test]
-// fn try_recv() {
-// let r = never::<i32>();
-// assert!(r.try_recv().is_err());
-
-// thread::sleep(ms(100));
-// assert!(r.try_recv().is_err());
-// }
-
-// #[test]
-// fn recv_timeout() {
-// let start = Instant::now();
-// let r = never::<i32>();
-
-// assert!(r.recv_timeout(ms(100)).is_err());
-// let now = Instant::now();
-// assert!(now - start >= ms(100));
-// assert!(now - start <= ms(150));
-
-// assert!(r.recv_timeout(ms(100)).is_err());
-// let now = Instant::now();
-// assert!(now - start >= ms(200));
-// assert!(now - start <= ms(250));
-// }