We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1e9de53 commit 8a2724fCopy full SHA for 8a2724f
lib/redis_client/cluster/pub_sub.rb
@@ -22,7 +22,7 @@ def close
22
23
def take_message(timeout)
24
@worker = subscribe(@client, timeout) if @worker.nil?
25
- return if @worker.join(0.01).nil?
+ return if @worker.alive?
26
27
message = @worker[:reply]
28
@worker = nil
0 commit comments