github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-28 16:48:13 -05:00
Code Issues Packages Projects Releases Wiki Activity

refactor: use impl IntoIterator for transaction batches and streamline validation calls (#16408)

Browse Source
This commit is contained in:
Acat
2025-05-22 19:14:17 +08:00
committed by GitHub
parent 6389242a53
commit e41d5ff4e1
4 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/optimism/txpool/src/validator.rs
View File

@@ -238,7 +238,7 @@ where
pub async fn validate_all_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Tx>,
transactions: impl IntoIterator<Item = Tx> + Send,
) -> Vec<TransactionValidationOutcome<Tx>> {
futures_util::future::join_all(
transactions.into_iter().map(|tx| self.validate_one(origin, tx)),
@@ -347,7 +347,7 @@ where
async fn validate_transactions_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Self::Transaction>,
transactions: impl IntoIterator<Item = Self::Transaction> + Send,
) -> Vec<TransactionValidationOutcome<Self::Transaction>> {
self.validate_all_with_origin(origin, transactions).await
}

4
crates/transaction-pool/src/lib.rs
View File

@@ -248,11 +248,11 @@ where
async fn validate_all(
&self,
origin: TransactionOrigin,
transactions: impl IntoIterator<Item = V::Transaction>,
transactions: impl IntoIterator<Item = V::Transaction> + Send,
) -> Vec<(TxHash, TransactionValidationOutcome<V::Transaction>)> {
self.pool
.validator()
.validate_transactions(transactions.into_iter().map(|tx| (origin, tx)).collect())
.validate_transactions_with_origin(origin, transactions)
.await
.into_iter()
.map(|tx| (tx.tx_hash(), tx))

6
crates/transaction-pool/src/validate/eth.rs
View File

@@ -113,7 +113,7 @@ where
pub fn validate_all_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Tx>,
transactions: impl IntoIterator<Item = Tx> + Send,
) -> Vec<TransactionValidationOutcome<Tx>> {
self.inner.validate_batch_with_origin(origin, transactions)
}
@@ -144,7 +144,7 @@ where
async fn validate_transactions_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Self::Transaction>,
transactions: impl IntoIterator<Item = Self::Transaction> + Send,
) -> Vec<TransactionValidationOutcome<Self::Transaction>> {
self.validate_all_with_origin(origin, transactions)
}
@@ -648,7 +648,7 @@ where
fn validate_batch_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Tx>,
transactions: impl IntoIterator<Item = Tx> + Send,
) -> Vec<TransactionValidationOutcome<Tx>> {
let mut provider = None;
transactions

4
crates/transaction-pool/src/validate/mod.rs
View File

@@ -214,7 +214,7 @@ pub trait TransactionValidator: Debug + Send + Sync {
fn validate_transactions_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Self::Transaction>,
transactions: impl IntoIterator<Item = Self::Transaction> + Send,
) -> impl Future<Output = Vec<TransactionValidationOutcome<Self::Transaction>>> + Send {
let futures = transactions.into_iter().map(|tx| self.validate_transaction(origin, tx));
futures_util::future::join_all(futures)
@@ -261,7 +261,7 @@ where
async fn validate_transactions_with_origin(
&self,
origin: TransactionOrigin,
transactions: Vec<Self::Transaction>,
transactions: impl IntoIterator<Item = Self::Transaction> + Send,
) -> Vec<TransactionValidationOutcome<Self::Transaction>> {
match self {
Self::Left(v) => v.validate_transactions_with_origin(origin, transactions).await,