Class: Puppeteer::TaskManager
- Inherits:
-
Object
- Object
- Puppeteer::TaskManager
- Defined in:
- lib/puppeteer/task_manager.rb
Instance Method Summary collapse
- #add(task) ⇒ Object
- #async_rerun_all ⇒ Object
- #delete(task) ⇒ Object
-
#initialize ⇒ TaskManager
constructor
A new instance of TaskManager.
- #terminate_all(error) ⇒ Object
Constructor Details
#initialize ⇒ TaskManager
Returns a new instance of TaskManager.
2 3 4 |
# File 'lib/puppeteer/task_manager.rb', line 2 def initialize @tasks = Set.new end |
Instance Method Details
#add(task) ⇒ Object
6 7 8 |
# File 'lib/puppeteer/task_manager.rb', line 6 def add(task) @tasks << task end |
#async_rerun_all ⇒ Object
21 22 23 |
# File 'lib/puppeteer/task_manager.rb', line 21 def async_rerun_all Concurrent::Promises.zip(*@tasks.map(&:async_rerun)) end |
#delete(task) ⇒ Object
10 11 12 |
# File 'lib/puppeteer/task_manager.rb', line 10 def delete(task) @tasks.delete(task) end |
#terminate_all(error) ⇒ Object
14 15 16 17 18 19 |
# File 'lib/puppeteer/task_manager.rb', line 14 def terminate_all(error) @tasks.each do |task| task.terminate(error) end @tasks.clear end |