Class: Observed::TaskFactory

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

Instance Method Summary collapse

Constructor Details

#initialize(args) ⇒ TaskFactory

Returns a new instance of TaskFactory.



136
137
138
139
 
# 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

Instance Method Details

#mutable_task(&block) ⇒ Object 



145
146
147
 
# File 'lib/observed/task.rb', line 145

def mutable_task(&block)
  MutableTask.new(task(&block))
end

#parallel(tasks) ⇒ Object 



149
150
151
 
# File 'lib/observed/task.rb', line 149

def parallel(tasks)
  ParallelTask.new(tasks)
end

#task(&block) ⇒ Object 



141
142
143
 
# File 'lib/observed/task.rb', line 141

def task(&block)
  ProcTask.new(executor: @executor, listener: @listener, &block)
end