Class: Observed::ParallelTask

Inherits:
Task
  • Object
show all
Defined in:
lib/observed/task.rb

Instance Attribute Summary

Attributes inherited from Task

#name

Instance Method Summary collapse

Methods inherited from Task

#compose, #then

Constructor Details

#initialize(tasks) ⇒ ParallelTask

Returns a new instance of ParallelTask.



60
61
62
63
 
# File 'lib/observed/task.rb', line 60

def initialize(tasks)
  @tasks = tasks || fail('tasks missing')
  @next_task = NoOpTask.instance
end

Instance Method Details

#now(data = {}, options = nil) ⇒ Object 



64
65
66
67
68
69
70
 
# File 'lib/observed/task.rb', line 64

def now(data={}, options=nil)
  @tasks.each do |task|
    task.now(data, options) do |data, options2|
      yield data, (options2 || options) if block_given?
    end
  end
end