Class: Liebre::Actor::RPC::Client::Task
- Inherits:
-
Object
- Object
- Liebre::Actor::RPC::Client::Task
- Defined in:
- lib/liebre/actor/rpc/client/task.rb
Instance Method Summary collapse
- #cancel_all ⇒ Object
- #every(interval, &block) ⇒ Object
-
#initialize ⇒ Task
constructor
A new instance of Task.
Constructor Details
#initialize ⇒ Task
Returns a new instance of Task.
9 10 11 |
# File 'lib/liebre/actor/rpc/client/task.rb', line 9 def initialize @tasks = [] end |
Instance Method Details
#cancel_all ⇒ Object
20 21 22 23 |
# File 'lib/liebre/actor/rpc/client/task.rb', line 20 def cancel_all tasks.each(&:shutdown) tasks.clear end |
#every(interval, &block) ⇒ Object
13 14 15 16 17 18 |
# 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 |