diff --git a/pubsub.go b/pubsub.go index 60903c0..87c5933 100644 --- a/pubsub.go +++ b/pubsub.go @@ -165,7 +165,7 @@ func (t *TwitchPubSub) reconnect() error { func (t *TwitchPubSub) Listen(topics []string) error { err := t.listen(topics) - if err != nil { + if err == nil { // Update topic list t.SubscribedTopics = append(t.SubscribedTopics, topics...) }