Sha256: 9a7c2b4cc4eb8dc807c674c0b5e1d7e442dc80024414c39e77e747e74bf20d2b
Contents?: true
Size: 652 Bytes
Versions: 17
Compression:
Stored size: 652 Bytes
Contents
module Dynflow module Testing class DummyExecutor attr_reader :world def initialize(world) @world = world @events_to_process = [] end def event(execution_plan_id, step_id, event, future = Future.new) @events_to_process << [execution_plan_id, step_id, event, future] end def progress events = @events_to_process.dup clear events.each do |execution_plan_id, step_id, event, future| future.resolve true world.action.execute event end end def clear @events_to_process.clear end end end end
Version data entries
17 entries across 17 versions & 1 rubygems