File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -349,6 +349,7 @@ pub enum WatchTxError {
349
349
Timeout ,
350
350
}
351
351
352
+ /// The type sent by the [`HeartbeatHandle`] to the [`Heartbeat`] background task.
352
353
#[ doc( alias = "TransactionWatcher" ) ]
353
354
struct TxWatcher {
354
355
config : PendingTransactionConfig ,
@@ -439,7 +440,6 @@ impl HeartbeatHandle {
439
440
}
440
441
}
441
442
442
- // TODO: Parameterize with `Network`
443
443
/// A heartbeat task that receives blocks and watches for transactions.
444
444
pub ( crate ) struct Heartbeat < N , S > {
445
445
/// The stream of incoming blocks to watch.
@@ -650,7 +650,7 @@ impl<N: Network, S: Stream<Item = N::BlockResponse> + Unpin + Send + 'static> He
650
650
651
651
impl < N : Network , S : Stream < Item = N :: BlockResponse > + Unpin + ' static > Heartbeat < N , S > {
652
652
fn consume ( self ) -> ( impl Future < Output = ( ) > , HeartbeatHandle ) {
653
- let ( ix_tx, ixns) = mpsc:: channel ( 16 ) ;
653
+ let ( ix_tx, ixns) = mpsc:: channel ( 64 ) ;
654
654
( self . into_future ( ixns) , HeartbeatHandle { tx : ix_tx } )
655
655
}
656
656
You can’t perform that action at this time.
0 commit comments