class Asynchronic::QueueEngine::Ost::Queue
Public Class Methods
new(name, redis)
click to toggle source
Calls superclass method
# File lib/asynchronic/queue_engine/ost.rb, line 58 def initialize(name, redis) super name self.redis = redis end
Public Instance Methods
empty?()
click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 67 def empty? redis.call!('EXISTS', key) == 0 end
pop()
click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 63 def pop redis.call! 'RPOP', key end
size()
click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 71 def size items.count end
to_a()
click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 75 def to_a items.reverse end