class Mutant::Parallel::Source::Array

Job source backed by a finite array

def initialize(*)

Returns:
  • (undefined) - 
def initialize(*)
  super
  @next_index = 0
end

def next

Raises:
  • (NoJobError) -

Returns:
  • (Job) - 
def next
  fail NoJobError unless next?
  Job.new(index: @next_index, payload: jobs.fetch(@next_index)).tap do
    @next_index += 1
  end
end

def next?

Returns:
  • (Boolean) - 
def next?
  @next_index < jobs.length
end