class LambdaPunch::Queue

Public Class Methods

jobs() click to toggle source
# File lib/lambda_punch/queue.rb, line 10
def jobs
  @jobs ||= Concurrent::Array.new
end
push(block) click to toggle source
# File lib/lambda_punch/queue.rb, line 6
def push(block)
  jobs << block
end

Public Instance Methods

call() click to toggle source
# File lib/lambda_punch/queue.rb, line 16
def call
  jobs.each do |job| 
    begin
      job.call
    rescue => e
      LambdaPunch.error_handler.call(e)
    end
  end
  true
ensure
  jobs.clear
end

Private Instance Methods

jobs() click to toggle source
# File lib/lambda_punch/queue.rb, line 31
def jobs
  self.class.jobs
end