Skip to content

Commit

Permalink
clippy consistency
Browse files Browse the repository at this point in the history
  • Loading branch information
rgbkrk committed Dec 13, 2024
1 parent 550cff0 commit d7d406d
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion benches/req_rep.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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));
})
});
});
}

Expand Down
2 changes: 1 addition & 1 deletion tests/helpers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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(())
Expand Down
4 changes: 2 additions & 2 deletions tests/pub_sub_compliant.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ async fn run_our_subs(our_subs: Vec<zeromq::SubSocket>, 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");
}
Expand Down Expand Up @@ -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");
}
}
}
Expand Down

0 comments on commit d7d406d

Please sign in to comment.