diff --git a/pubsub.go b/pubsub.go index c465078e..e1164093 100644 --- a/pubsub.go +++ b/pubsub.go @@ -468,6 +468,7 @@ func (c *PubSub) initPing() { } c.mu.Lock() c.reconnect(pingErr) + healthy = true c.mu.Unlock() } case <-c.exit: