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