fix: panic on rueidiscompat.SSubscribe due to unnecessary PING

Signed-off-by: Rueian <rueiancsie@gmail.com>
redis · Sep 16, 2024 · deab6ca · deab6ca
1 parent 5135acd
commit deab6ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rueidiscompat/pubsub.go b/rueidiscompat/pubsub.go
@@ -282,7 +282,7 @@ func (p *pubsub) resubscribe(ctx context.Context) rueidis.DedicatedClient {
 	defer p.mu.Unlock()
 retry:
 	c := p.mconn()
-	ok := false
+	ok := len(p.schannels) == 0 && len(p.channels) == 0 && len(p.patterns) == 0
 	if len(p.schannels) != 0 {
 		builder := c.B().Ssubscribe().Channel()
 		for channel, ok := range p.schannels {