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