class AcpcTableManager::Receiver
Public Instance Methods
subscribe_with_timeout() { |parse| ... }
click to toggle source
# File lib/acpc_table_manager.rb, line 51 def subscribe_with_timeout list, message = @redis.blpop( @channel, timeout: AcpcTableManager.config.maintenance_interval_s ) if message yield JSON.parse(message) else raise SubscribeTimeout end end