mirror of
https://github.com/paradigmxyz/reth.git
synced 2026-04-30 03:01:58 -04:00
chore: fix clippy (#19118)
This commit is contained in:
@@ -570,7 +570,7 @@ pub struct BlockState<N: NodePrimitives = EthPrimitives> {
|
||||
/// The executed block that determines the state after this block has been executed.
|
||||
block: ExecutedBlock<N>,
|
||||
/// The block's parent block if it exists.
|
||||
parent: Option<Arc<BlockState<N>>>,
|
||||
parent: Option<Arc<Self>>,
|
||||
}
|
||||
|
||||
impl<N: NodePrimitives> BlockState<N> {
|
||||
|
||||
@@ -2402,7 +2402,7 @@ pub enum DiscoveryUpdate {
|
||||
/// Node that was removed from the table
|
||||
Removed(PeerId),
|
||||
/// A series of updates
|
||||
Batch(Vec<DiscoveryUpdate>),
|
||||
Batch(Vec<Self>),
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
|
||||
@@ -284,9 +284,7 @@ impl<N: NetworkPrimitives> TransactionFetcher<N> {
|
||||
|
||||
// folds size based on expected response size and adds selected hashes to the request
|
||||
// list and the other hashes to the surplus list
|
||||
loop {
|
||||
let Some((hash, metadata)) = hashes_from_announcement_iter.next() else { break };
|
||||
|
||||
for (hash, metadata) in hashes_from_announcement_iter.by_ref() {
|
||||
let Some((_ty, size)) = metadata else {
|
||||
unreachable!("this method is called upon reception of an eth68 announcement")
|
||||
};
|
||||
|
||||
@@ -236,6 +236,7 @@ impl EngineNodeLauncher {
|
||||
|
||||
info!(target: "reth::cli", "Consensus engine initialized");
|
||||
|
||||
#[allow(clippy::needless_continue)]
|
||||
let events = stream_select!(
|
||||
event_sender.new_listener().map(Into::into),
|
||||
pipeline_events.map(Into::into),
|
||||
|
||||
@@ -188,7 +188,7 @@ pub(crate) enum Scenario {
|
||||
HigherNonce { onchain: u64, nonce: u64 },
|
||||
Multi {
|
||||
// Execute multiple test scenarios
|
||||
scenario: Vec<Scenario>,
|
||||
scenario: Vec<Self>,
|
||||
},
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user