fix lints in all targets & features

Author: cowlicks

benches/throughput.rs

@@ -41,8 +41,8 @@ fn bench_throughput(c: &mut Criterion) {
                     let num_streams = n_streams;
                     let limit = *len / num_streams;
                     b.to_async(&rt).iter_custom(|iters| async move {
-                        let socka = UdxSocket::bind("127.0.0.1:0").await.unwrap();
-                        let sockb = UdxSocket::bind("127.0.0.1:0").await.unwrap();
+                        let socka = UdxSocket::bind("127.0.0.1:0").unwrap();
+                        let sockb = UdxSocket::bind("127.0.0.1:0").unwrap();
                         let addra = socka.local_addr().unwrap();
                         let addrb = sockb.local_addr().unwrap();
                         let mut readers = vec![];
@@ -191,8 +191,8 @@ async fn setup_pipe_tcp() -> io::Result<(TcpStream, TcpStream)> {
 }
 
 async fn setup_pipe_udx() -> io::Result<(UdxStream, UdxStream)> {
-    let socka = UdxSocket::bind("127.0.0.1:0").await?;
-    let sockb = UdxSocket::bind("127.0.0.1:0").await?;
+    let socka = UdxSocket::bind("127.0.0.1:0")?;
+    let sockb = UdxSocket::bind("127.0.0.1:0")?;
     let addra = socka.local_addr()?;
     let addrb = sockb.local_addr()?;
     let streama = socka.connect(addrb, 1, 2)?;

examples/bench.rs

@@ -77,7 +77,7 @@ fn usize_from_env(name: &str, default: usize) -> usize {
     std::env::var(name)
         .map(|x| {
             x.parse::<usize>()
-                .expect(&format!("{} must be a number", name))
+                .unwrap_or_else(|_| panic!("{} must be a number", name))
         })
         .unwrap_or(default)
 }

examples/multi_stream.rs

@@ -33,9 +33,9 @@ async fn main() {
         let i = i as u32;
         let streama = socka.connect(addrb, 1000 + i, i).unwrap();
         let streamb = sockb.connect(addra, i, 1000 + i).unwrap();
-        let read_buf = vec![0u8; MSGSIZE as usize];
-        let write_buf = vec![i as u8; MSGSIZE as usize];
-        let (reader, writer) = if i % 2 == 0 {
+        let read_buf = vec![0u8; MSGSIZE];
+        let write_buf = vec![i as u8; MSGSIZE];
+        let (reader, writer) = if i.is_multiple_of(2) {
             (streama, streamb)
         } else {
             (streamb, streama)

src/mutex.rs

@@ -47,7 +47,7 @@ mod tracking {
         /// Acquires the lock for a certain purpose
         ///
         /// The purpose will be recorded in the list of last lock owners
-        pub fn lock(&self, purpose: &'static str) -> MutexGuard<T> {
+        pub fn lock(&self, purpose: &'static str) -> MutexGuard<'_, T> {
             let now = Instant::now();
             let guard = self.inner.lock();