Contents

class JobQueue::TestAdapter
  def initialize
    @queue = []
  end
  
  def put(string)
    @queue << string
  end
  
  def subscribe(error_report, &block)
    loop do
      begin
        sleep 0.1 if @queue.empty?
        yield @queue.shift
      rescue
        error_report.call(job.body, e)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
mloughran-job_queue-0.0.3	lib/job_queue/adapters/test_adapter.rb
strobemonkey-job_queue-0.0.5	lib/job_queue/adapters/test_adapter.rb