github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-26 07:38:59 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore: relax mempool impl (#12865)

Browse Source
This commit is contained in:
Matthias Seitz
2024-11-26 11:12:36 +01:00
committed by GitHub
parent 13cd77c935
commit 9d2e04c77e
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
crates/net/eth-wire-types/src/broadcast.rs
View File

@@ -1,15 +1,14 @@
//! Types for broadcasting new data.
use crate::{EthMessage, EthVersion, NetworkPrimitives};
use alloy_primitives::{Bytes, TxHash, B256, U128};
use alloy_rlp::{
Decodable, Encodable, RlpDecodable, RlpDecodableWrapper, RlpEncodable, RlpEncodableWrapper,
};
use alloy_primitives::{Bytes, TxHash, B256, U128};
use derive_more::{Constructor, Deref, DerefMut, From, IntoIterator};
use reth_codecs_derive::{add_arbitrary_tests, generate_tests};
use reth_primitives::{PooledTransactionsElement, TransactionSigned};
use reth_primitives::TransactionSigned;
use reth_primitives_traits::SignedTransaction;
use std::{
collections::{HashMap, HashSet},
mem,
@@ -555,7 +554,7 @@ pub trait HandleVersionedMempoolData {
fn msg_version(&self) -> EthVersion;
}
impl HandleMempoolData for Vec<PooledTransactionsElement> {
impl<T: SignedTransaction> HandleMempoolData for Vec<T> {
fn is_empty(&self) -> bool {
self.is_empty()
}
@@ -565,7 +564,7 @@ impl HandleMempoolData for Vec<PooledTransactionsElement> {
}
fn retain_by_hash(&mut self, mut f: impl FnMut(&TxHash) -> bool) {
self.retain(|tx| f(tx.hash()))
self.retain(|tx| f(tx.tx_hash()))
}
}