bahtya dd3c923f44 fix: close pubsub connection on Subscribe error in CancelationPubSub ...

When redis.Subscribe succeeds but Receive() fails, the pubsub
connection was not being closed before returning the error. This caused
the subscriber goroutine to leak a Redis connection on each retry
iteration, eventually exhausting the connection pool.

Fixes #1095

2026-04-09 18:15:48 +08:00

50 KiB

Raw Permalink Blame History

View Raw