Remove indirection in initial sync completion

[rapid-gossip-sync-server] / src / lib.rs

diff --git a/src/lib.rs b/src/lib.rs
index 07a40c538756bd77df01b7ea64d5546a14bc9f7d..8ab4803773c3206b8ea8863f1d6319496c42e403 100644 (file)
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -87,11 +87,11 @@ impl RapidSyncProcessor {
                let initial_sync_complete = self.initial_sync_complete.clone();
 
                if config::DOWNLOAD_NEW_GOSSIP {
-                       let (mut persister, persistence_sender) =
-                               GossipPersister::new(sync_completion_sender, Arc::clone(&self.network_graph));
+                       let (mut persister, persistence_sender) = GossipPersister::new(Arc::clone(&self.network_graph));
 
                        println!("Starting gossip download");
-                       tokio::spawn(tracking::download_gossip(persistence_sender, Arc::clone(&self.network_graph)));
+                       tokio::spawn(tracking::download_gossip(persistence_sender, sync_completion_sender,
+                               Arc::clone(&self.network_graph)));
                        println!("Starting gossip db persistence listener");
                        tokio::spawn(async move { persister.persist_gossip().await; });
                } else {