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