Class: Playwright::Waiter

Inherits:
Object
  • Object
show all
Defined in:
lib/playwright/waiter.rb

Overview

ref: github.com/microsoft/playwright-python/blob/v1.40.0/playwright/_impl/_waiter.py ref: github.com/microsoft/playwright/blob/v1.40.0/packages/playwright-core/src/client/waiter.ts

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(channel_owner, wait_name:) ⇒ Waiter

Returns a new instance of Waiter.



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/playwright/waiter.rb', line 7

def initialize(channel_owner, wait_name:)
  @result = Concurrent::Promises.resolvable_future
  @wait_id = SecureRandom.hex(16)
  @event = wait_name
  @channel = channel_owner.channel
  @registered_listeners = Set.new
  @listeners_mutex = Mutex.new
  @logs = []
  wait_for_event_info_before
end

Instance Attribute Details

#result ⇒ Object (readonly)

Returns the value of attribute result.



134
135
136
 
# File 'lib/playwright/waiter.rb', line 134

def result
  @result
end

Instance Method Details

#force_fulfill(result) ⇒ Object 



80
81
82
 
# File 'lib/playwright/waiter.rb', line 80

def force_fulfill(result)
  fulfill(result)
end

#force_reject(error) ⇒ Object 



84
85
86
 
# File 'lib/playwright/waiter.rb', line 84

def force_reject(error)
  reject(error)
end

#log(message) ⇒ Object 



136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
 
# File 'lib/playwright/waiter.rb', line 136

def log(message)
  @logs << message
  begin
    @channel.async_send_message_to_server(
      "waitForEventInfo",
      {
        "info": {
          "waitId": @wait_id,
          "phase": "log",
          "message": message,
        },
      },
    )
  rescue => err
    # ignore
  end
end

#reject_on_event(emitter, event, error_or_proc, predicate: nil) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/playwright/waiter.rb', line 44

def reject_on_event(emitter, event, error_or_proc, predicate: nil)
  listener = -> (*args) {
    if !predicate || predicate.call(*args)
      if error_or_proc.respond_to?(:call)
        reject(error_or_proc.call)
      else
        reject(error_or_proc)
      end
    end
  }
  register_listener(emitter, event, listener)

  self
end

#reject_on_timeout(timeout_ms, message) ⇒ Object 



59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/playwright/waiter.rb', line 59

def reject_on_timeout(timeout_ms, message)
  return if timeout_ms <= 0

  Concurrent::Promises.schedule(timeout_ms / 1000.0) do
    reject(TimeoutError.new(message: message))
  end.rescue do |err|
    puts err, err.backtrace
  end

  self
end

#wait_for_event(emitter, event, predicate: nil) ⇒ Object

Parameters:



106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/playwright/waiter.rb', line 106

def wait_for_event(emitter, event, predicate: nil)
  listener = -> (*args) {
    begin
      if !predicate || predicate.call(*args)
        fulfill(args.first)
      end
    rescue => err
      reject(err)
    end
  }
  register_listener(emitter, event, listener)

  self
end