Class: Baleen::RunnerManager

Inherits:
Object
  • Object
show all
Defined in:
lib/baleen/runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(connection, task) ⇒ RunnerManager

Returns a new instance of RunnerManager.



7
8
9
10
 
# File 'lib/baleen/runner.rb', line 7

def initialize(connection, task)
  @task       = task
  @connection = connection
end

Instance Method Details

#run {|@task| ... } ⇒ Object

Yields:

  • (@task) 


12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/baleen/runner.rb', line 12

def run
  results = []
  prepare_task
  create_runners.each do |runners|
    runners.map{|runner| runner.future.run}.each do |actor|
      results << actor.value
    end
  end
  @task.results = results
  yield @task
end