Module: Mutant::Parallel

Defined in:
lib/mutant/parallel.rb,
lib/mutant/parallel/source.rb,
lib/mutant/parallel/worker.rb,
lib/mutant/parallel/master.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

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:


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