Merge pull request #24 from jkczyz/2021-07-background-processor

Explicitly stop BackgroundProcessor

diff --git a/src/main.rs b/src/main.rs
index bfb586adfbe630c3df9ff7fc31b51c67d493ff9c..57f0bb2ea7f9017c42feb5b6ef7b9b8818bbda7d 100644 (file)
--- a/src/main.rs
+++ b/src/main.rs
@@ -551,7 +551,7 @@ async fn start_ldk() {
        let persist_channel_manager_callback =
                move |node: &ChannelManager| FilesystemPersister::persist_manager(data_dir.clone(), &*node);
        // Step 17: Background Processing
-       BackgroundProcessor::start(
+       let background_processor = BackgroundProcessor::start(
                persist_channel_manager_callback,
                event_handler,
                chain_monitor.clone(),
@@ -610,6 +610,9 @@ async fn start_ldk() {
                network,
        )
        .await;
+
+       // Stop the background processor.
+       background_processor.stop().unwrap();
 }
 
 #[tokio::main]