class Observed::TaskFactory
Public Class Methods
new(args)
click to toggle source
# File lib/observed/task.rb, line 136 def initialize(args) @executor = args[:executor] || fail('Missing a value for :executor') @listener = args[:listener] || TaskListener.new end
Public Instance Methods
mutable_task(&block)
click to toggle source
# File lib/observed/task.rb, line 145 def mutable_task(&block) MutableTask.new(task(&block)) end
parallel(tasks)
click to toggle source
# File lib/observed/task.rb, line 149 def parallel(tasks) ParallelTask.new(tasks) end
task(&block)
click to toggle source
# File lib/observed/task.rb, line 141 def task(&block) ProcTask.new(executor: @executor, listener: @listener, &block) end