Prevent self re-subscription

2019-07-15 16:32:05 +08:00 · 2019-07-15 16:32:05 +08:00 · f25d97fbd3
commit f25d97fbd3
parent 6d9ec7a9c5
1 changed files with 4 additions and 0 deletions
--- a/libp2p/pubsub/pubsub.py
+++ b/libp2p/pubsub/pubsub.py
@ -209,6 +209,10 @@ class Pubsub():
        :param topic_id: topic_id to subscribe to
        """

+        # Already subscribed
+        if topic_id in self.my_topics:
+            return self.my_topics[topic_id]
+
        # Map topic_id to blocking queue
        self.my_topics[topic_id] = asyncio.Queue()