diff --git a/gossip/util/pubsub.go b/gossip/util/pubsub.go index 34e679962bb..8c36401f00a 100644 --- a/gossip/util/pubsub.go +++ b/gossip/util/pubsub.go @@ -97,10 +97,9 @@ func (ps *PubSub) Subscribe(topic string, ttl time.Duration) Subscription { s = NewSet() ps.subscriptions[topic] = s } - ps.Unlock() - // Add the subscription s.Add(sub) + ps.Unlock() // When the timeout expires, remove the subscription time.AfterFunc(ttl, func() {