Sha256: d0fc970b6967987fec6ce8e6f13faa4865a588409eca32584ba84d53f5ef57d3
Contents?: true
Size: 685 Bytes
Versions: 17
Compression:
Stored size: 685 Bytes
Contents
module Dynflow
module DelayedExecutors
class Abstract
attr_reader :core
def initialize(world, options = {})
@world = world
@options = options
spawn
end
def start
@core.ask(:start)
end
def terminate
@core.ask(:terminate!)
end
def spawn
Concurrent.future.tap do |initialized|
@core = core_class.spawn name: 'delayed-executor',
args: [@world, @options],
initialized: initialized
end
end
private
def core_class
raise NotImplementedError
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems