Sha256: 3c53270bbafd8eb70477d3fea89cf532c78e080ddb2b51dab7d29de1f349bd31
Contents?: true
Size: 1.06 KB
Versions: 7
Compression:
Stored size: 1.06 KB
Contents
class Puppeteer::WebSocketTransport
# @param {string} url
# @return [Puppeteer::WebSocketTransport]
def self.create(url)
ws = Puppeteer::WebSocket.new(
url: url,
max_payload_size: 256 * 1024 * 1024, # 256MB
)
promise = resolvable_future
ws.on_open do
promise.fulfill(Puppeteer::WebSocketTransport.new(ws))
end
ws.on_error do |error_message|
promise.reject(Puppeteer::WebSocktTransportError.new(error_message))
end
promise.value!
end
# @param {!WebSocket::Driver} web_socket
def initialize(web_socket)
@ws = web_socket
@ws.on_message do |data|
@on_message&.call(data)
end
@ws.on_close do |reason, code|
@on_close&.call(reason, code)
end
@ws.on_error do |error|
# Silently ignore all errors - we don't know what to do with them.
end
end
# @param message [String]
def send_text(message)
@ws.send_text(message)
end
def close
@ws.close
end
def on_close(&block)
@on_close = block
end
def on_message(&block)
@on_message = block
end
end
Version data entries
7 entries across 7 versions & 1 rubygems