@@ -78,7 +78,7 @@ use {crate::utils::BlockchainClient::Esplora, bdk_esplora::EsploraAsyncExt};
7878#[ cfg( feature = "rpc" ) ]
7979use {
8080 crate :: utils:: BlockchainClient :: RpcClient ,
81- bdk_bitcoind_rpc:: { Emitter , bitcoincore_rpc:: RpcApi } ,
81+ bdk_bitcoind_rpc:: { Emitter , NO_EXPECTED_MEMPOOL_TXS , bitcoincore_rpc:: RpcApi } ,
8282 bdk_wallet:: chain:: { BlockId , CanonicalizationParams , CheckPoint } ,
8383} ;
8484
@@ -645,8 +645,12 @@ pub(crate) async fn handle_online_wallet_subcommand(
645645 height : 0 ,
646646 hash : genesis_block. block_hash ( ) ,
647647 } ) ;
648- let mut emitter =
649- Emitter :: new ( & * client, genesis_cp. clone ( ) , genesis_cp. height ( ) , [ ] . iter ( ) ) ;
648+ let mut emitter = Emitter :: new (
649+ & * client,
650+ genesis_cp. clone ( ) ,
651+ genesis_cp. height ( ) ,
652+ NO_EXPECTED_MEMPOOL_TXS ,
653+ ) ;
650654
651655 while let Some ( block_event) = emitter. next_block ( ) ? {
652656 if block_event. block_height ( ) % 10_000 == 0 {
@@ -668,7 +672,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
668672 }
669673
670674 let mempool_txs = emitter. mempool ( ) ?;
671- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
675+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
672676 }
673677 #[ cfg( feature = "cbf" ) ]
674678 KyotoClient { client } => {
@@ -748,7 +752,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
748752 }
749753
750754 let mempool_txs = emitter. mempool ( ) ?;
751- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
755+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
752756 }
753757 #[ cfg( feature = "cbf" ) ]
754758 KyotoClient { client } => {
0 commit comments