lints

Author: cowlicks

src/sstream/sm2.rs

@@ -639,6 +639,7 @@ mod tests {
         }
     }
 
+    #[allow(clippy::type_complexity)]
     fn create_mock_io_pair() -> (
         MockIo<impl Stream<Item = Result<Vec<u8>, std::io::Error>>>,
         mpsc::UnboundedSender<Result<Vec<u8>, std::io::Error>>,
@@ -743,10 +744,9 @@ mod tests {
         let (mut lm, mut rm) = connected_machines();
 
         let payload = b"Hello, World!".to_vec();
-        lm.handshake_start(&payload);
-        //let (lres, rres) = join!(lm.send(b"foo"), rm.next()); // TODO this hangs
+        lm.handshake_start(&payload)?;
         let (lres, rres) = join!(lm.flush(), rm.next());
-        assert!(matches!(rres, Some(Event::HandshakePayload(payload))));
+        assert!(matches!(rres, Some(Event::HandshakePayload(_))));
         lres?;
         Ok(())
     }
@@ -763,14 +763,14 @@ mod tests {
         };
 
         let (empty, rtol, ltor): (Vec<u8>, _, _) = (vec![], b"rtol".to_vec(), b"ltor".to_vec());
-        assert!(matches!(lr, Event::HandshakePayload(empty)));
-        assert!(matches!(rr, Event::HandshakePayload(empty)));
+        assert!(matches!(lr, Event::HandshakePayload(x) if x == empty));
+        assert!(matches!(rr, Event::HandshakePayload(x) if x == empty));
 
         let (Some(lr), Some(rr)) = join!(lm.next(), rm.next()) else {
             panic!()
         };
-        assert!(matches!(lr, Event::Message(rtol)));
-        assert!(matches!(rr, Event::Message(ltor)));
+        assert!(matches!(lr, Event::Message(x) if x == rtol));
+        assert!(matches!(rr, Event::Message(x) if x == ltor));
 
         Ok(())
     }