From b501ab15320d6528dd61da45617665b6ba0af56e Mon Sep 17 00:00:00 2001 From: Septias Date: Sat, 18 May 2024 18:05:44 +0200 Subject: [PATCH] keep lock longer --- src/peer_channels.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/peer_channels.rs b/src/peer_channels.rs index e98ae921a..b894ea911 100644 --- a/src/peer_channels.rs +++ b/src/peer_channels.rs @@ -90,6 +90,7 @@ impl Iroh { 0 }; + let mut channels = self.iroh_channels.write().await; let peers = get_iroh_gossip_peers(ctx, msg_id).await?; info!( ctx, @@ -115,10 +116,7 @@ impl Iroh { .join(topic, peers.into_iter().map(|addr| addr.node_id).collect()) .await?; - self.iroh_channels - .write() - .await - .insert(topic, ChannelState::new(seq, subscribe_loop)); + channels.insert(topic, ChannelState::new(seq, subscribe_loop)); Ok(Some(connect_future)) }