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

chore: swap order for canon stream (#19242)

Browse Source
This commit is contained in:
Matthias Seitz
2025-10-22 22:38:53 +02:00
committed by GitHub
parent 4f6cc7a359
commit 346ef408a4
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/optimism/rpc/src/eth/transaction.rs
View File

@@ -95,8 +95,8 @@ where
let this = self.clone();
let timeout_duration = self.send_raw_transaction_sync_timeout();
async move {
let hash = EthTransactions::send_raw_transaction(&this, tx).await?;
let mut canonical_stream = this.provider().canonical_state_stream();
let hash = EthTransactions::send_raw_transaction(&this, tx).await?;
let flashblock_rx = this.pending_block_rx();
let mut flashblock_stream = flashblock_rx.map(WatchStream::new);

2
crates/rpc/rpc-eth-api/src/helpers/transaction.rs
View File

@@ -91,8 +91,8 @@ pub trait EthTransactions: LoadTransaction<Provider: BlockReaderIdExt> {
let this = self.clone();
let timeout_duration = self.send_raw_transaction_sync_timeout();
async move {
let hash = EthTransactions::send_raw_transaction(&this, tx).await?;
let mut stream = this.provider().canonical_state_stream();
let hash = EthTransactions::send_raw_transaction(&this, tx).await?;
tokio::time::timeout(timeout_duration, async {
while let Some(notification) = stream.next().await {
let chain = notification.committed();