class Playwright::Connection
def initialize(transport)
def initialize(transport) @transport = transport @transport.on_message_received do |message| dispatch(message) end @transport.on_driver_crashed do @callbacks.each_value do |callback| callback.reject(::Playwright::DriverCrashedError.new) end raise ::Playwright::DriverCrashedError.new end @objects = {} # Hash[ guid => ChannelOwner ] @waiting_for_object = {} # Hash[ guid => Promise<ChannelOwner> ] @callbacks = {} # Hash [ guid => Promise<ChannelOwner> ] @root_object = RootChannelOwner.new(self) @remote = false @tracing_count = 0 @closed_error = nil end