Class: Puppeteer::TaskManager

Inherits:
Object
  • Object
show all
Defined in:
lib/puppeteer/task_manager.rb

Instance Method Summary collapse

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