diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py index 3aeb10ab..5e518774 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