We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d6aa1bc commit 6424fb2Copy full SHA for 6424fb2
lightning/src/ln/channel.rs
@@ -5941,6 +5941,17 @@ impl<Signer: Sign> Channel<Signer> {
5941
self.update_time_counter += 1;
5942
(monitor_update, dropped_outbound_htlcs)
5943
}
5944
+
5945
+ pub fn inflight_htlc_sources(&self) -> impl Iterator<Item=&HTLCSource> {
5946
+ self.holding_cell_htlc_updates.iter()
5947
+ .flat_map(|htlc_update| {
5948
+ match htlc_update {
5949
+ HTLCUpdateAwaitingACK::AddHTLC { source, .. } => { Some(source) }
5950
+ _ => { None }
5951
+ }
5952
+ })
5953
+ .chain(self.pending_outbound_htlcs.iter().map(|htlc| &htlc.source))
5954
5955
5956
5957
const SERIALIZATION_VERSION: u8 = 2;
0 commit comments