@@ -1219,8 +1219,8 @@ fn test_no_preimage_inbound_htlc_balances() {
12191219 let as_htlc_timeout_claim = nodes[ 0 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . split_off ( 0 ) ;
12201220 assert_eq ! ( as_htlc_timeout_claim. len( ) , 1 ) ;
12211221 check_spends ! ( as_htlc_timeout_claim[ 0 ] , as_txn[ 0 ] ) ;
1222- expect_pending_htlcs_forwardable_conditions ! ( nodes[ 0 ] ,
1223- [ HTLCHandlingFailureType :: Receive { payment_hash : to_a_failed_payment_hash } ] ) ;
1222+ expect_pending_htlcs_forwardable_conditions ( nodes[ 0 ] . node . get_and_clear_pending_events ( ) , & [ HTLCHandlingFailureType :: Receive { payment_hash : to_a_failed_payment_hash } ] ) ;
1223+ nodes [ 0 ] . node . process_pending_htlc_forwards ( ) ;
12241224
12251225 assert_eq ! ( as_pre_spend_claims,
12261226 sorted_vec( nodes[ 0 ] . chain_monitor. chain_monitor. get_monitor( chan_id) . unwrap( ) . get_claimable_balances( ) ) ) ;
@@ -1237,8 +1237,8 @@ fn test_no_preimage_inbound_htlc_balances() {
12371237 // The next few blocks for B look the same as for A, though for the opposite HTLC
12381238 nodes[ 1 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . clear ( ) ;
12391239 connect_blocks ( & nodes[ 1 ] , TEST_FINAL_CLTV - ( ANTI_REORG_DELAY - 1 ) ) ;
1240- expect_pending_htlcs_forwardable_conditions ! ( nodes[ 1 ] ,
1241- [ HTLCHandlingFailureType :: Receive { payment_hash : to_b_failed_payment_hash } ] ) ;
1240+ expect_pending_htlcs_forwardable_conditions ( nodes[ 1 ] . node . get_and_clear_pending_events ( ) , & [ HTLCHandlingFailureType :: Receive { payment_hash : to_b_failed_payment_hash } ] ) ;
1241+ nodes [ 1 ] . node . process_pending_htlc_forwards ( ) ;
12421242 let bs_htlc_timeout_claim = nodes[ 1 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . split_off ( 0 ) ;
12431243 assert_eq ! ( bs_htlc_timeout_claim. len( ) , 1 ) ;
12441244 check_spends ! ( bs_htlc_timeout_claim[ 0 ] , as_txn[ 0 ] ) ;
0 commit comments