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