From b00130449215617a4ad0e688021397d15fca551e Mon Sep 17 00:00:00 2001 From: "hinto.janai" Date: Fri, 20 Sep 2024 16:19:50 -0400 Subject: [PATCH] review fixes --- p2p/p2p/src/broadcast.rs | 2 +- p2p/p2p/src/sync_states.rs | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/p2p/p2p/src/broadcast.rs b/p2p/p2p/src/broadcast.rs index c314c74..c36dbb6 100644 --- a/p2p/p2p/src/broadcast.rs +++ b/p2p/p2p/src/broadcast.rs @@ -337,7 +337,7 @@ impl Stream for BroadcastMessageStream { } else { tracing::trace!("Diffusion flush timer expired but no txs to diffuse"); // poll next_flush now to register the waker with it. - // the waker will already be registered with the block broadcast channel." + // the waker will already be registered with the block broadcast channel. #[expect(clippy::let_underscore_must_use)] let _ = this.next_flush.poll(cx); Poll::Pending diff --git a/p2p/p2p/src/sync_states.rs b/p2p/p2p/src/sync_states.rs index 982d199..0c03795 100644 --- a/p2p/p2p/src/sync_states.rs +++ b/p2p/p2p/src/sync_states.rs @@ -193,7 +193,10 @@ impl PeerSyncSvc { tracing::debug!( "Updating sync watcher channel with new highest seen cumulative difficulty: {new_cumulative_difficulty}" ); - #[expect(clippy::let_underscore_must_use, reason = "TODO")] + #[expect( + clippy::let_underscore_must_use, + reason = "dropped receivers can be ignored" + )] let _ = self.new_height_watcher.send(NewSyncInfo { top_hash: core_sync_data.top_id, chain_height: core_sync_data.current_height,