jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: listen for all transactions (#4436)

Browse Source
This commit is contained in:
Matthias Seitz
2023-08-31 13:06:24 -07:00
committed by GitHub
parent 1a40daef8a
commit d8a7ee2eb4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
examples/network-txpool.rs
View File

@ -11,8 +11,8 @@ use reth_network::{config::rng_secret_key, NetworkConfig, NetworkManager};
use reth_provider::test_utils::NoopProvider;
use reth_transaction_pool::{
blobstore::InMemoryBlobStore, validate::ValidTransaction, CoinbaseTipOrdering,
EthPooledTransaction, PoolTransaction, TransactionOrigin, TransactionPool,
TransactionValidationOutcome, TransactionValidator,
EthPooledTransaction, PoolTransaction, TransactionListenerKind, TransactionOrigin,
TransactionPool, TransactionValidationOutcome, TransactionValidator,
};
#[tokio::main]
@ -46,7 +46,7 @@ async fn main() -> eyre::Result<()> {
tokio::task::spawn(txpool);
// listen for new transactions
let mut txs = pool.pending_transactions_listener();
let mut txs = pool.pending_transactions_listener_for(TransactionListenerKind::All);
while let Some(tx) = txs.recv().await {
println!("Received new transaction: {:?}", tx);