Fix panics?

sigp · Jan 18, 2024 · 7b4c1f9 · 7b4c1f9
1 parent b96b908
commit 7b4c1f9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/protocols/gossipsub/src/behaviour.rs b/protocols/gossipsub/src/behaviour.rs
@@ -1995,6 +1995,9 @@ where
 
         // remove unsubscribed peers from the mesh if it exists
         for (peer_id, topic_hash) in unsubscribed_peers {
+            self.fanout
+                .get_mut(&topic_hash)
+                .map(|peers| peers.remove(&peer_id));
             self.remove_peer_from_mesh(&peer_id, &topic_hash, None, false, Churn::Unsub);
         }