f Account for PendingHTLCsForwardable being dropped

Author: tnull

src/event.rs

@@ -57,7 +57,6 @@ use core::task::{Poll, Waker};
 use std::collections::VecDeque;
 use std::ops::Deref;
 use std::sync::{Arc, Condvar, Mutex, RwLock};
-use std::time::Duration;
 
 /// An event emitted by [`Node`], which should be handled by the user.
 ///
@@ -1045,22 +1044,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 runtime_lock = self.runtime.read().unwrap();
-				debug_assert!(runtime_lock.is_some());
-
-				if let Some(runtime) = runtime_lock.as_ref() {
-					runtime.spawn(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();
-					});
-				}
-			},
 			LdkEvent::SpendableOutputs { outputs, channel_id } => {
 				match self
 					.output_sweeper
@@ -1161,7 +1144,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