From 4bcc3d22aa91d92f37e5739d3759f54aad8a5688 Mon Sep 17 00:00:00 2001
From: dignifiedquire <me@dignifiedquire.com>
Date: Sat, 18 May 2024 16:27:33 +0200
Subject: [PATCH] subscribe before join

---
 src/peer_channels.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/peer_channels.rs b/src/peer_channels.rs
index 0efeb8991..2c9c51f99 100644
--- a/src/peer_channels.rs
+++ b/src/peer_channels.rs
@@ -101,11 +101,6 @@ impl Iroh {
             self.endpoint.add_node_addr(peer.clone())?;
         }
 
-        let connect_future = self
-            .gossip
-            .join(topic, peers.into_iter().map(|addr| addr.node_id).collect())
-            .await?;
-
         let ctx = ctx.clone();
         let gossip = self.gossip.clone();
         let subscribe_loop = tokio::spawn(async move {
@@ -114,6 +109,11 @@ impl Iroh {
             }
         });
 
+        let connect_future = self
+            .gossip
+            .join(topic, peers.into_iter().map(|addr| addr.node_id).collect())
+            .await?;
+
         self.iroh_channels
             .write()
             .await