module RRRSpec::PersisterQueue

Constants

PERSISTER_QUEUE_KEY

Public Instance Methods

dequeue() click to toggle source

Public: Wait for the persistence request.

# File lib/rrrspec/redis_models.rb, line 80
def dequeue
  _, line = RRRSpec.redis.blpop(PERSISTER_QUEUE_KEY, 0)
  Taskset.new(line)
end
empty?() click to toggle source
# File lib/rrrspec/redis_models.rb, line 85
def empty?
  RRRSpec.redis.llen(PERSISTER_QUEUE_KEY) == 0
end
enqueue(taskset) click to toggle source

Public: Request the taskset to be persisted.

# File lib/rrrspec/redis_models.rb, line 75
def enqueue(taskset)
  RRRSpec.redis.rpush(PERSISTER_QUEUE_KEY, taskset.key)
end