@@ -1219,8 +1219,8 @@ fn test_no_preimage_inbound_htlc_balances() {
1219
1219
let as_htlc_timeout_claim = nodes[ 0 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . split_off ( 0 ) ;
1220
1220
assert_eq ! ( as_htlc_timeout_claim. len( ) , 1 ) ;
1221
1221
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 ( ) ;
1224
1224
1225
1225
assert_eq ! ( as_pre_spend_claims,
1226
1226
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() {
1237
1237
// The next few blocks for B look the same as for A, though for the opposite HTLC
1238
1238
nodes[ 1 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . clear ( ) ;
1239
1239
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 ( ) ;
1242
1242
let bs_htlc_timeout_claim = nodes[ 1 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . split_off ( 0 ) ;
1243
1243
assert_eq ! ( bs_htlc_timeout_claim. len( ) , 1 ) ;
1244
1244
check_spends ! ( bs_htlc_timeout_claim[ 0 ] , as_txn[ 0 ] ) ;
0 commit comments