@@ -74,7 +74,7 @@ use {crate::utils::BlockchainClient::Esplora, bdk_esplora::EsploraAsyncExt};
7474#[ cfg( feature = "rpc" ) ]
7575use {
7676 crate :: utils:: BlockchainClient :: RpcClient ,
77- bdk_bitcoind_rpc:: { Emitter , bitcoincore_rpc:: RpcApi } ,
77+ bdk_bitcoind_rpc:: { Emitter , NO_EXPECTED_MEMPOOL_TXS , bitcoincore_rpc:: RpcApi } ,
7878 bdk_wallet:: chain:: { BlockId , CanonicalizationParams , CheckPoint } ,
7979} ;
8080
@@ -400,8 +400,12 @@ pub(crate) async fn handle_online_wallet_subcommand(
400400 height : 0 ,
401401 hash : genesis_block. block_hash ( ) ,
402402 } ) ;
403- let mut emitter =
404- Emitter :: new ( & * client, genesis_cp. clone ( ) , genesis_cp. height ( ) , [ ] . iter ( ) ) ;
403+ let mut emitter = Emitter :: new (
404+ & * client,
405+ genesis_cp. clone ( ) ,
406+ genesis_cp. height ( ) ,
407+ NO_EXPECTED_MEMPOOL_TXS ,
408+ ) ;
405409
406410 while let Some ( block_event) = emitter. next_block ( ) ? {
407411 if block_event. block_height ( ) % 10_000 == 0 {
@@ -423,7 +427,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
423427 }
424428
425429 let mempool_txs = emitter. mempool ( ) ?;
426- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
430+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
427431 }
428432 #[ cfg( feature = "cbf" ) ]
429433 KyotoClient { client } => {
@@ -503,7 +507,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
503507 }
504508
505509 let mempool_txs = emitter. mempool ( ) ?;
506- wallet. apply_unconfirmed_txs ( mempool_txs. new_txs . into_iter ( ) ) ;
510+ wallet. apply_unconfirmed_txs ( mempool_txs. update ) ;
507511 }
508512 #[ cfg( feature = "cbf" ) ]
509513 KyotoClient { client } => {
0 commit comments