Class: Mutant::Parallel::Driver Private

Inherits:
Object
  • Object
show all
Includes:
Adamantium::Flat
Defined in:
lib/mutant/parallel/driver.rb

Overview

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.

Driver for parallelized execution

Instance Method Summary collapse

Instance Method Details

#wait_timeout(timeout) ⇒ Variable::Result<Sink#status>

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.

Wait for computation to finish, with timeout

Parameters:

  • timeout (Float)

Returns:

  • (Variable::Result<Sink#status>)

    current status



22
23
24
25
26
# File 'lib/mutant/parallel/driver.rb', line 22

def wait_timeout(timeout)
  var_final.take_timeout(timeout)

  finalize(status)
end