Module: Mutant::Parallel

Defined in:: lib/mutant/parallel.rb,
lib/mutant/parallel/master.rb,
lib/mutant/parallel/source.rb,
lib/mutant/parallel/worker.rb

Overview

Parallel excecution engine of arbitrary payloads

Defined Under Namespace

Classes: Config, Driver, Job, JobResult, Master, Sink, Source, Status, Worker

Class Method Summary collapse

.async(config) ⇒ Driver private

Run async computation returing driver.

Class Method Details

.async(config) ⇒ `Driver`

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 async computation returing driver

Returns:

(Driver)



37
38
39

# File 'lib/mutant/parallel.rb', line 37

def self.async(config)
  Driver.new(config.env.new_mailbox.bind(Master.call(config)))
end