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