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 be32f1f commit d56b359Copy full SHA for d56b359
lib/redis_client/cluster/pub_sub.rb
@@ -64,12 +64,12 @@ def close
64
def next_event(timeout = nil)
65
return if @state_list.empty?
66
67
+ @state_list.shuffle!
68
max_duration = calc_max_duration(timeout)
69
starting = obtain_current_time
70
loop do
71
break if max_duration > 0 && obtain_current_time - starting > max_duration
72
- @state_list.shuffle!
73
@state_list.each do |pubsub|
74
message = pubsub.take_message(timeout)
75
return message if message
0 commit comments