File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed
Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -11009,7 +11009,7 @@ where
1100911009 fn release_held_htlc(&self, _message: ReleaseHeldHtlc, _context: AsyncPaymentsContext) {}
1101011010
1101111011 fn release_pending_messages(&self) -> Vec<(AsyncPaymentsMessage, MessageSendInstructions)> {
11012- Vec::new( )
11012+ core::mem::take(&mut self.pending_async_payments_messages.lock().unwrap() )
1101311013 }
1101411014}
1101511015
Original file line number Diff line number Diff line change @@ -1765,6 +1765,14 @@ where
17651765 ) ;
17661766 }
17671767
1768+ #[ cfg( async_payments) ] {
1769+ for ( message, instructions) in self . async_payments_handler . release_pending_messages ( ) {
1770+ let _ = self . send_onion_message_internal (
1771+ message, instructions, format_args ! ( "when sending AsyncPaymentsMessage" )
1772+ ) ;
1773+ }
1774+ }
1775+
17681776 // Enqueue any initiating `CustomMessage`s to send.
17691777 for ( message, instructions) in self . custom_handler . release_pending_custom_messages ( ) {
17701778 let _ = self . send_onion_message_internal (
You can’t perform that action at this time.
0 commit comments