summaryrefslogtreecommitdiffstats
path: root/tokio/src/runtime/thread_pool/tests/queue.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tokio/src/runtime/thread_pool/tests/queue.rs')
-rw-r--r--tokio/src/runtime/thread_pool/tests/queue.rs14
1 files changed, 5 insertions, 9 deletions
diff --git a/tokio/src/runtime/thread_pool/tests/queue.rs b/tokio/src/runtime/thread_pool/tests/queue.rs
index ef0e373c..83a60275 100644
--- a/tokio/src/runtime/thread_pool/tests/queue.rs
+++ b/tokio/src/runtime/thread_pool/tests/queue.rs
@@ -41,9 +41,8 @@ macro_rules! assert_steal {
macro_rules! assert_empty {
($q:expr) => {{
let q: &mut queue::Worker<Noop> = &mut $q;
- match q.pop_local_first() {
- Some(v) => panic!("expected emtpy queue; got {}", num(v)),
- None => {}
+ if let Some(v) = q.pop_local_first() {
+ panic!("expected emtpy queue; got {}", num(v));
}
}};
}
@@ -261,12 +260,9 @@ fn num(task: Task<Noop>) -> u32 {
for (_, join) in map.iter_mut() {
let mut cx = Context::from_waker(noop_waker_ref());
- match Pin::new(join).poll(&mut cx) {
- Ready(n) => {
- num = Some(n.unwrap());
- break;
- }
- _ => {}
+ if let Ready(n) = Pin::new(join).poll(&mut cx) {
+ num = Some(n.unwrap());
+ break;
}
}