From a8d9536b086d1fcef87d9bdee6d4dd29d2d21a1f Mon Sep 17 00:00:00 2001 From: NIC619 Date: Mon, 4 Nov 2019 18:26:38 +0800 Subject: [PATCH] Spin up `handle_dead_peer_queue` task --- libp2p/pubsub/pubsub.py | 1 + 1 file changed, 1 insertion(+) diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py index 3aeb10a..5e51877 100644 --- 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