Class: Mutant::Parallel::Worker Private

Inherits:
Object
  • Object
show all
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

Instance Method Details

#callself

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

Returns:

  • (self)


20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
# File 'lib/mutant/parallel/worker.rb', line 20

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