Sha256: 425193ae2a64a1a66b0f8f3e1cdc803965b095085f47cd26119e5d71c41effa8
Contents?: true
Size: 685 Bytes
Versions: 23
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
private
def core_class
raise NotImplementedError
end
def spawn
Concurrent.future.tap do |initialized|
@core = core_class.spawn name: 'delayed-executor',
args: [@world, @options],
initialized: initialized
end
end
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems