# File lib/dynflow/delayed_executors/abstract.rb, line 7 def initialize(world, options = {}) @world = world @options = options spawn end
# File lib/dynflow/delayed_executors/abstract.rb, line 21 def spawn Concurrent.future.tap do |initialized| @core = core_class.spawn name: 'delayed-executor', args: [@world, @options], initialized: initialized end end
# File lib/dynflow/delayed_executors/abstract.rb, line 13 def start @core.ask(:start) end
# File lib/dynflow/delayed_executors/abstract.rb, line 17 def terminate @core.ask(:terminate!) end
# File lib/dynflow/delayed_executors/abstract.rb, line 31 def core_class raise NotImplementedError end