From dbbe3bc8ef9bb51635caf943ff823a1555a8224e Mon Sep 17 00:00:00 2001
From: songluyu <songluyu@baidu.com>
Date: Mon, 20 Nov 2023 16:19:14 +0800
Subject: [PATCH] add pubsub close

---
 internal/rdb/rdb.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go
index c79a9c5..9b00137 100644
--- a/internal/rdb/rdb.go
+++ b/internal/rdb/rdb.go
@@ -1451,6 +1451,7 @@ func (r *RDB) CancelationPubSub() (*redis.PubSub, error) {
 	pubsub := r.client.Subscribe(ctx, base.CancelChannel)
 	_, err := pubsub.Receive(ctx)
 	if err != nil {
+		_ = pubsub.Close()
 		return nil, errors.E(op, errors.Unknown, fmt.Sprintf("redis pubsub receive error: %v", err))
 	}
 	return pubsub, nil