Spin up handle_dead_peer_queue task

2019-11-04 18:26:38 +08:00 · 2019-11-04 18:26:38 +08:00 · a8d9536b08
commit a8d9536b08
parent 84f5210220
1 changed files with 1 additions and 0 deletions
--- a/libp2p/pubsub/pubsub.py
+++ b/libp2p/pubsub/pubsub.py
@ -141,6 +141,7 @@ class Pubsub:

        # Call handle peer to keep waiting for updates to peer queue
        asyncio.ensure_future(self.handle_peer_queue())
+        asyncio.ensure_future(self.handle_dead_peer_queue())

    def get_hello_packet(self) -> rpc_pb2.RPC:
        """Generate subscription message with all topics we are subscribed to