Class: Mutant::Parallel::Worker Private
- Inherits:
-
Object
- Object
- Mutant::Parallel::Worker
- Includes:
- Adamantium::Flat
- Defined in:
- lib/mutant/parallel/worker.rb
This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.
Instance Method Summary collapse
-
#call ⇒ self
private
Run worker payload.
Instance Method Details
#call ⇒ self
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
Run worker payload
ignore :reek:TooManyStatements
22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/mutant/parallel/worker.rb', line 22 def call loop do job = next_job or break job_start(job) result = processor.call(job.payload) job_done(job) break if add_result(result) end finalize self end |