lib/redis/subscribe.rb in redis-3.0.6 vs lib/redis/subscribe.rb in redis-3.0.7
- old
+ new
@@ -37,10 +37,11 @@
sub.callbacks[type].call(*rest)
unsubscribed = type == stop && rest.last == 0
break if unsubscribed
end
ensure
- send(stop) if !unsubscribed
+ # No need to unsubscribe here. The real client closes the connection
+ # whenever an exception is raised (see #ensure_connected).
end
end
end
class Subscription