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