class Liebre::Actor::RPC::Client::Task

Attributes

tasks[R]

Public Class Methods

new() click to toggle source
# File lib/liebre/actor/rpc/client/task.rb, line 9
def initialize
  @tasks = []
end

Public Instance Methods

cancel_all() click to toggle source
# File lib/liebre/actor/rpc/client/task.rb, line 20
def cancel_all
  tasks.each(&:shutdown)
  tasks.clear
end
every(interval, &block) click to toggle source
# File lib/liebre/actor/rpc/client/task.rb, line 13
def every interval, &block
  task = Concurrent::TimerTask.new(execution_interval: interval, &block)
  tasks << task

  task.execute
end