diff --git a/crates/provider/src/heart.rs b/crates/provider/src/heart.rs index 75be6a0091e..a52a138eb49 100644 --- a/crates/provider/src/heart.rs +++ b/crates/provider/src/heart.rs @@ -349,6 +349,7 @@ pub enum WatchTxError { Timeout, } +/// The type sent by the [`HeartbeatHandle`] to the [`Heartbeat`] background task. #[doc(alias = "TransactionWatcher")] struct TxWatcher { config: PendingTransactionConfig, @@ -439,7 +440,6 @@ impl HeartbeatHandle { } } -// TODO: Parameterize with `Network` /// A heartbeat task that receives blocks and watches for transactions. pub(crate) struct Heartbeat { /// The stream of incoming blocks to watch. @@ -650,7 +650,7 @@ impl + Unpin + Send + 'static> He impl + Unpin + 'static> Heartbeat { fn consume(self) -> (impl Future, HeartbeatHandle) { - let (ix_tx, ixns) = mpsc::channel(16); + let (ix_tx, ixns) = mpsc::channel(64); (self.into_future(ixns), HeartbeatHandle { tx: ix_tx }) }