f Account for PendingHTLCsForwardable being dropped

Author: tnull

src/event.rs

@@ -59,7 +59,6 @@ use core::task::{Poll, Waker};
 use std::collections::VecDeque;
 use std::ops::Deref;
 use std::sync::{Arc, Condvar, Mutex};
-use std::time::Duration;
 
 /// An event emitted by [`Node`], which should be handled by the user.
 ///
@@ -1048,19 +1047,6 @@ where
 					liquidity_source.handle_htlc_handling_failed(failure_type);
 				}
 			},
-			LdkEvent::PendingHTLCsForwardable { time_forwardable } => {
-				let forwarding_channel_manager = self.channel_manager.clone();
-				let min = time_forwardable.as_millis() as u64;
-
-				let future = async move {
-					let millis_to_sleep = thread_rng().gen_range(min..min * 5) as u64;
-					tokio::time::sleep(Duration::from_millis(millis_to_sleep)).await;
-
-					forwarding_channel_manager.process_pending_htlc_forwards();
-				};
-
-				self.runtime.spawn_cancellable_background_task(future);
-			},
 			LdkEvent::SpendableOutputs { outputs, channel_id } => {
 				match self
 					.output_sweeper
@@ -1161,7 +1147,7 @@ where
 					}
 				}
 
-				let user_channel_id: u128 = rand::thread_rng().gen::<u128>();
+				let user_channel_id: u128 = thread_rng().gen::<u128>();
 				let allow_0conf = self.config.trusted_peers_0conf.contains(&counterparty_node_id);
 				let mut channel_override_config = None;
 				if let Some((lsp_node_id, _)) = self