diff --git a/lib/redis.rb b/lib/redis.rb index c6b8f7003..286585ee9 100644 --- a/lib/redis.rb +++ b/lib/redis.rb @@ -175,6 +175,7 @@ def _subscription(method, timeout, channels, block) @subscription_client.send(method, *channels, &block) end ensure + @subscription_client&.close @subscription_client = nil end else