class Observed::ParallelTask

Public Class Methods

new(tasks) click to toggle source
# File lib/observed/task.rb, line 60
def initialize(tasks)
  @tasks = tasks || fail('tasks missing')
  @next_task = NoOpTask.instance
end

Public Instance Methods

now(data={}, options=nil) { |data, (options2 || options)| ... } click to toggle source
# 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