From 6d9ec7a9c5717c45108437e9d8d128758d7a2ba4 Mon Sep 17 00:00:00 2001 From: NIC619 Date: Mon, 15 Jul 2019 16:28:29 +0800 Subject: [PATCH] Handle the unsubscribe case --- libp2p/pubsub/pubsub.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py index e0f6580f..3e8f74c9 100644 --- a/libp2p/pubsub/pubsub.py +++ b/libp2p/pubsub/pubsub.py @@ -107,8 +107,7 @@ class Pubsub(): # to know that it is subscribed to the topic (doesn't # need everyone to know) for message in rpc_incoming.subscriptions: - if message.subscribe: - self.handle_subscription(peer_id, message) + self.handle_subscription(peer_id, message) if should_publish: # relay message to peers with router