@@ -68,7 +68,7 @@ use {crate::utils::BlockchainClient::Esplora, bdk_esplora::EsploraAsyncExt};
6868#[ cfg( feature = "rpc" ) ]
6969use {
7070 crate :: utils:: BlockchainClient :: RpcClient ,
71- bdk_bitcoind_rpc:: { Emitter , bitcoincore_rpc:: RpcApi } ,
71+ bdk_bitcoind_rpc:: { Emitter , NO_EXPECTED_MEMPOOL_TXS , bitcoincore_rpc:: RpcApi } ,
7272 bdk_wallet:: chain:: { BlockId , CanonicalizationParams , CheckPoint } ,
7373} ;
7474
@@ -394,8 +394,12 @@ pub(crate) async fn handle_online_wallet_subcommand(
394394 height : 0 ,
395395 hash : genesis_block. block_hash ( ) ,
396396 } ) ;
397- let mut emitter =
398- Emitter :: new ( & * client, genesis_cp. clone ( ) , genesis_cp. height ( ) , [ ] . iter ( ) ) ;
397+ let mut emitter = Emitter :: new (
398+ & * client,
399+ genesis_cp. clone ( ) ,
400+ genesis_cp. height ( ) ,
401+ NO_EXPECTED_MEMPOOL_TXS ,
402+ ) ;
399403
400404 while let Some ( block_event) = emitter. next_block ( ) ? {
401405 if block_event. block_height ( ) % 10_000 == 0 {
@@ -417,7 +421,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
417421 }
418422
419423 let mempool_txs = emitter. mempool ( ) ?;
420- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
424+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
421425 }
422426 #[ cfg( feature = "cbf" ) ]
423427 KyotoClient { client } => {
@@ -497,7 +501,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
497501 }
498502
499503 let mempool_txs = emitter. mempool ( ) ?;
500- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
504+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
501505 }
502506 #[ cfg( feature = "cbf" ) ]
503507 KyotoClient { client } => {
0 commit comments