Sha256: f2c33da53d9f56ecbfe866711e4d9c029aaeaebdd54b9609e197eab1ab385080
Contents?: true
Size: 1.29 KB
Versions: 68
Compression:
Stored size: 1.29 KB
Contents
# frozen_string_literal: true
module Mutant
module Parallel
# Job source for parallel execution
class Source
include AbstractType
class Job
include Adamantium, Anima.new(:index, :payload)
end
NoJobError = Class.new(RuntimeError)
# Next job
#
# @return [Object]
#
# @raise [NoJobError]
# when no next job is available
abstract_method :next
# Test if next job is available
#
# @return [Boolean]
abstract_method :next?
# Job source backed by a finite array
class Array
include Concord.new(:jobs)
# Initialize objecto
#
# @return [undefined]
def initialize(*)
super
@next_index = 0
end
# Test if next job is available
#
# @return [Boolean]
def next?
@next_index < jobs.length
end
# Next job
#
# @return [Job]
#
# @raise [NoJobError]
# when no next job is available
def next
fail NoJobError unless next?
Job.new(index: @next_index, payload: jobs.fetch(@next_index)).tap do
@next_index += 1
end
end
end # Array
end # Source
end # Parallel
end # Mutant
Version data entries
68 entries across 68 versions & 1 rubygems