Class: Puppeteer::Bidi::TaskManager

Inherits:
Object
  • Object
show all
Defined in:
lib/puppeteer/bidi/task_manager.rb,
sig/puppeteer/bidi/task_manager.rbs

Overview

TaskManager tracks active WaitTask instances to enable coordinated lifecycle management This is a faithful port of Puppeteer's TaskManager implementation: https://github.com/puppeteer/puppeteer/blob/main/packages/puppeteer-core/src/common/WaitTask.ts

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TaskManager

Returns a new instance of TaskManager.



11
12
13
 
# File 'lib/puppeteer/bidi/task_manager.rb', line 11

def initialize
  @tasks = Set.new
end

Instance Method Details

#add(task) ⇒ void

This method returns an undefined value.

Add a task to the manager Corresponds to Puppeteer's add(task: WaitTask): void

Parameters:



19
20
21
 
# File 'lib/puppeteer/bidi/task_manager.rb', line 19

def add(task)
  @tasks.add(task)
end

#delete(task) ⇒ void

This method returns an undefined value.

Delete a task from the manager Corresponds to Puppeteer's delete(task: WaitTask): void

Parameters:



27
28
29
 
# File 'lib/puppeteer/bidi/task_manager.rb', line 27

def delete(task)
  @tasks.delete(task)
end

#rerun_all ⇒ void

This method returns an undefined value.

Rerun all tasks in parallel Corresponds to Puppeteer's async rerunAll(): Promise



45
46
47
 
# File 'lib/puppeteer/bidi/task_manager.rb', line 45

def rerun_all
  @tasks.each(&:rerun)
end

#terminate_all(error = nil) ⇒ void

This method returns an undefined value.

Terminate all tasks with an optional error Corresponds to Puppeteer's terminateAll(error?: Error): void

Parameters:

  • error (Exception, nil) (defaults to: nil) 


35
36
37
38
39
40
 
# File 'lib/puppeteer/bidi/task_manager.rb', line 35

def terminate_all(error = nil)
  @tasks.each do |task|
    task.terminate(error)
  end
  @tasks.clear
end