Contents

module Legion
  module Supervision
    class << self
      attr_accessor :timer_tasks
      def setup
        @timer_tasks = Concurrent::AtomicReference.new([])
        @once_tasks = Concurrent::AtomicReference.new([])
        @loop_tasks = Concurrent::AtomicReference.new([])
        @poll_tasks = Concurrent::AtomicReference.new([])
        @subscriptions = Concurrent::AtomicReference.new([])
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
legionio-0.2.0	lib/legion/supervison.rb