Method: Dynflow::Testing::InThreadExecutor#execute

Defined in:
lib/dynflow/testing/in_thread_executor.rb

#execute(execution_plan_id, finished = Concurrent::Promises.resolvable_future, _wait_for_acceptance = true) ⇒ Object 



12
13
14
15
16
 
# File 'lib/dynflow/testing/in_thread_executor.rb', line 12

def execute(execution_plan_id, finished = Concurrent::Promises.resolvable_future, _wait_for_acceptance = true)
  feed_queue(@director.start_execution(execution_plan_id, finished))
  process_work_items
  finished
end