@@ -2486,18 +2486,16 @@ where
2486
2486
return Err ( APIError :: ChannelUnavailable { err : "Peer for first hop currently disconnected" . to_owned ( ) } ) ;
2487
2487
}
2488
2488
let funding_txo = chan. get ( ) . get_funding_txo ( ) . unwrap ( ) ;
2489
- match {
2490
- break_chan_entry ! ( self , chan. get_mut( ) . send_htlc_and_commit(
2491
- htlc_msat, payment_hash. clone( ) , htlc_cltv, HTLCSource :: OutboundRoute {
2492
- path: path. clone( ) ,
2493
- session_priv: session_priv. clone( ) ,
2494
- first_hop_htlc_msat: htlc_msat,
2495
- payment_id,
2496
- payment_secret: payment_secret. clone( ) ,
2497
- payment_params: payment_params. clone( ) ,
2498
- } , onion_packet, & self . logger) ,
2499
- chan)
2500
- } {
2489
+ let send_res = chan. get_mut ( ) . send_htlc_and_commit ( htlc_msat, payment_hash. clone ( ) ,
2490
+ htlc_cltv, HTLCSource :: OutboundRoute {
2491
+ path : path. clone ( ) ,
2492
+ session_priv : session_priv. clone ( ) ,
2493
+ first_hop_htlc_msat : htlc_msat,
2494
+ payment_id,
2495
+ payment_secret : payment_secret. clone ( ) ,
2496
+ payment_params : payment_params. clone ( ) ,
2497
+ } , onion_packet, & self . logger ) ;
2498
+ match break_chan_entry ! ( self , send_res, chan) {
2501
2499
Some ( monitor_update) => {
2502
2500
let update_id = monitor_update. update_id ;
2503
2501
let update_res = self . chain_monitor . update_channel ( funding_txo, monitor_update) ;
0 commit comments