class Gotta::Queue::Memory::Driver
Attributes
name[R]
Public Class Methods
new(name)
click to toggle source
# File lib/gotta/queue/memory.rb, line 29 def initialize(name) @name = name @queue = ::Queue.new end
Public Instance Methods
pop()
click to toggle source
# File lib/gotta/queue/memory.rb, line 34 def pop @queue.pop end
process() { |pop| ... }
click to toggle source
# File lib/gotta/queue/memory.rb, line 42 def process loop do yield pop end end
push(value)
click to toggle source
# File lib/gotta/queue/memory.rb, line 38 def push(value) @queue.push(value) end