We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3600925 commit 413a70aCopy full SHA for 413a70a
lib/redis_client/cluster/pub_sub.rb
@@ -64,10 +64,12 @@ def next_event(timeout = nil)
64
65
max_duration = calc_max_duration(timeout)
66
starting = obtain_current_time
67
+ clients = @states.values
68
loop do
69
break if max_duration > 0 && obtain_current_time - starting > max_duration
70
- @states.values.shuffle.each do |pubsub|
71
+ clients.shuffle!
72
+ clients.each do |pubsub|
73
message = pubsub.take_message(timeout)
74
return message if message
75
end
0 commit comments