diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py index cebc438b3..a1a2d9f0f 100644 --- a/libp2p/pubsub/gossipsub.py +++ b/libp2p/pubsub/gossipsub.py @@ -262,7 +262,6 @@ async def publish(self, msg_forwarder: ID, pubsub_msg: rpc_pb2.Message) -> None: continue stream = self.pubsub.peers[peer_id] - # TODO: Go use `sendRPC`, which possibly piggybacks gossip/control messages. await self.pubsub.write_msg(stream, rpc_msg) for topic in pubsub_msg.topicIDs: