Update libp2p/pubsub/gossipsub.py
Co-Authored-By: Kevin Mai-Husan Chia <mhchia@users.noreply.github.com>
This commit is contained in:
parent
2d3bfc8184
commit
a675da52ee
|
@ -235,7 +235,7 @@ class GossipSub(IPubsubRouter):
|
||||||
gossipsub_peers = self.mesh[topic]
|
gossipsub_peers = self.mesh[topic]
|
||||||
else:
|
else:
|
||||||
# When we publish to a topic that we have not subscribe to, we randomly pick
|
# When we publish to a topic that we have not subscribe to, we randomly pick
|
||||||
# `self.degree` number of peers who have subscribe to the topic and add them
|
# `self.degree` number of peers who have subscribed to the topic and add them
|
||||||
# as our `fanout` peers.
|
# as our `fanout` peers.
|
||||||
topic_in_fanout: bool = topic in self.fanout
|
topic_in_fanout: bool = topic in self.fanout
|
||||||
fanout_peers: List[ID] = self.fanout[topic] if topic_in_fanout else []
|
fanout_peers: List[ID] = self.fanout[topic] if topic_in_fanout else []
|
||||||
|
|
Loading…
Reference in New Issue
Block a user