Create event subscription earlier to avoid missed events

equalitie · Oct 11, 2023 · f2b7149 · f2b7149
1 parent 1eaebac
commit f2b7149
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/src/network/server.rs b/lib/src/network/server.rs
@@ -251,13 +251,15 @@ impl<'a> Monitor<'a> {
     }
 
     async fn run(self) -> Result<()> {
-        self.handle_all_branches_changed().await?;
-
+        // Important: make sure to create the event subscription first, before calling
+        // `handle_all_branches_changed` otherwise we might miss some events.
         let mut events = pin!(Throttle::new(
             events(self.vault.event_tx.subscribe()),
             Duration::from_secs(1)
         ));
 
+        self.handle_all_branches_changed().await?;
+
         while let Some(event) = events.next().await {
             match event {
                 BranchChanged::One(branch_id) => self.handle_branch_changed(branch_id).await?,