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