subscribe before join

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