chore: clippy

ceramicnetwork · May 13, 2024 · 95d2eda · 95d2eda
1 parent ec0470c
commit 95d2eda
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 14 deletions.
diff --git a/recon/src/libp2p.rs b/recon/src/libp2p.rs
@@ -24,13 +24,13 @@ use libp2p::{
     swarm::{ConnectionId, NetworkBehaviour, NotifyHandler, ToSwarm},
 };
 use libp2p_identity::PeerId;
+use std::collections::VecDeque;
+use std::task::Waker;
 use std::{
     collections::{btree_map::Entry, BTreeMap},
     task::Poll,
     time::{Duration, Instant},
 };
-use std::collections::VecDeque;
-use std::task::Waker;
 use tracing::{debug, trace, warn};
 
 pub use crate::protocol::Recon;

diff --git a/recon/src/libp2p/tests.rs b/recon/src/libp2p/tests.rs
@@ -213,9 +213,7 @@ mod loomtest {
                 MockReconForEventId::new(),
                 Config::default(),
             );
-            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| {
-                behavior.poll(cx)
-            })));
+            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| behavior.poll(cx))));
             assert!(res.is_none())
         });
     }
@@ -239,9 +237,7 @@ mod loomtest {
                     last_sync: None,
                 },
             );
-            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| {
-                behavior.poll(cx)
-            })));
+            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| behavior.poll(cx))));
             assert!(res.is_none());
         });
     }
@@ -255,19 +251,15 @@ mod loomtest {
                 Config::default(),
             );
             let mut behavior = std::pin::Pin::new(&mut behavior);
-            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| {
-                behavior.poll(cx)
-            })));
+            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| behavior.poll(cx))));
             assert!(res.is_none());
 
             behavior.send_event(ToSwarm::GenerateEvent(Event::PeerEvent(PeerEvent {
                 remote_peer_id: PEER_ID.parse().unwrap(),
                 status: PeerStatus::Waiting,
             })));
 
-            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| {
-                behavior.poll(cx)
-            })));
+            let res = loom::future::block_on(poll_immediate(poll_fn(|cx| behavior.poll(cx))));
 
             assert!(res.is_some());
         });