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