diff --git a/waku/node/subscription_manager.nim b/waku/node/subscription_manager.nim index 98afe2fae..661c57004 100644 --- a/waku/node/subscription_manager.nim +++ b/waku/node/subscription_manager.nim @@ -156,8 +156,8 @@ proc subscribeShard*( added = true if added: self.edgeFilterWakeup.fire() - if not isNil(self.node.wakuRelay): - discard self.node.doRelaySubscribe(shard, handler) + if not isNil(self.node.wakuRelay): + discard self.node.doRelaySubscribe(shard, handler) return ok() proc unsubscribeShard*( @@ -198,8 +198,8 @@ proc subscribe*( added = true if added: self.edgeFilterWakeup.fire() - if not isNil(self.node.wakuRelay): - discard self.node.doRelaySubscribe(shard, handler) + if not isNil(self.node.wakuRelay): + discard self.node.doRelaySubscribe(shard, handler) return ok() proc unsubscribe*(