Skip to content

Commit 618d437

Browse files
committed
f action runner
1 parent 7b1ee8f commit 618d437

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

lightning/src/ln/channelmanager.rs

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -4592,23 +4592,19 @@ impl<M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelManager<M, T, K, F
45924592
}
45934593

45944594
fn handle_monitor_update_completion_actions<I: IntoIterator<Item=MonitorUpdateCompletionAction>>(&self, actions: I) {
4595-
let mut actions = actions.into_iter().peekable();
4596-
if actions.peek().is_none() { return; }
4597-
4598-
let mut pending_events = self.pending_events.lock().unwrap();
4599-
for action in actions {
4595+
for action in actions.into_iter() {
46004596
match action {
46014597
MonitorUpdateCompletionAction::PaymentClaimed { payment_hash } => {
46024598
if let Some(ClaimingPayment { amount_msat, payment_purpose: purpose, receiver_node_id }) =
46034599
self.claimable_payments.lock().unwrap().pending_claimed_payments.remove(&payment_hash)
46044600
{
4605-
pending_events.push(events::Event::PaymentClaimed {
4601+
self.pending_events.lock().unwrap().push(events::Event::PaymentClaimed {
46064602
payment_hash, purpose, amount_msat, receiver_node_id: Some(receiver_node_id),
46074603
});
46084604
}
46094605
},
46104606
MonitorUpdateCompletionAction::EmitEvent { event } => {
4611-
pending_events.push(event);
4607+
self.pending_events.lock().unwrap().push(event);
46124608
},
46134609
}
46144610
}

0 commit comments

Comments
 (0)