diff --git a/benches/req_rep.rs b/benches/req_rep.rs index d759e1d..1bbaa11 100644 --- a/benches/req_rep.rs +++ b/benches/req_rep.rs @@ -61,7 +61,7 @@ fn criterion_benchmark(c: &mut Criterion) { async_std::task::block_on(iter_fn(&mut req, &mut rep)); #[cfg(feature = "async-dispatcher-runtime")] async_dispatcher::block_on(iter_fn(&mut req, &mut rep)); - }) + }); }); } diff --git a/tests/helpers.rs b/tests/helpers.rs index e102a1e..ccb606a 100644 --- a/tests/helpers.rs +++ b/tests/helpers.rs @@ -52,7 +52,7 @@ pub async fn run_req_client( assert_eq!( format!("Req - {}, Rep - {}", i, i), String::from_utf8(repl.get(0).unwrap().to_vec()).unwrap() - ) + ); } req_socket.close().await; Ok(()) diff --git a/tests/pub_sub_compliant.rs b/tests/pub_sub_compliant.rs index 21a5916..075d8ef 100644 --- a/tests/pub_sub_compliant.rs +++ b/tests/pub_sub_compliant.rs @@ -60,7 +60,7 @@ async fn run_our_subs(our_subs: Vec, num_to_recv: u32) { }) }); for h in join_handles { - h.await.expect("Subscriber task panicked!") + h.await.expect("Subscriber task panicked!"); } println!("Finished sub task"); } @@ -128,7 +128,7 @@ mod test { // https://github.com/zeromq/libzmq/issues/3387 // So we will delete it ourselves. if let Some(path) = e.strip_prefix("ipc://") { - std::fs::remove_file(path).expect("Failed to remove ipc file") + std::fs::remove_file(path).expect("Failed to remove ipc file"); } } }