core/dev.kdriver.core.connection/DefaultConnection

DefaultConnection

open class DefaultConnection(websocketUrl: String, messageListeningScope: CoroutineScope, var targetInfo: <Error class: unknown class>? = null, var owner: Browser? = null) : OwnedConnection

Default implementation of the Connection interface.

Inheritors

DefaultTab

Constructors

DefaultConnection

constructor(websocketUrl: String, messageListeningScope: CoroutineScope, targetInfo: <Error class: unknown class>? = null, owner: Browser? = null)

Types

Companion

object Companion

Properties

attached

open val attached: Boolean?

browserContextId

open val browserContextId: String?

canAccessOpener

open val canAccessOpener: Boolean?

events

open val events: Flow<<Error class: unknown class>>

generatedDomains

open val generatedDomains: MutableMap<KClass<out <Error class: unknown class>>, <Error class: unknown class>>

openerFrameId

open val openerFrameId: String?

openerId

open val openerId: String?

owner

open override var owner: Browser?

responses

open val responses: Flow<<Error class: unknown class>>

subtype

open val subtype: String?

targetId

open val targetId: String?

targetInfo

open override var targetInfo: <Error class: unknown class>?

title

open val title: String?

type

open val type: String?

url

open val url: String?

Functions

addHandler

inline fun <T> Connection.addHandler(coroutineScope: CoroutineScope, crossinline event: <Error class: unknown class>.() -> Flow<T>, crossinline handler: suspend (T) -> Unit): Job

Adds a handler for a specific CDP event.

callCommand

open suspend override fun callCommand(method: String, parameter: JsonElement?, mode: <Error class: unknown class>): JsonElement?

Internal method to call a CDP command.

open suspend override fun close()

Closes the websocket connection. Should not be called manually by users.

registerReconnectRestore

open suspend override fun registerReconnectRestore(key: Any, restore: suspend () -> Unit)

Registers a restore action to be re-run automatically after the connection transparently reconnects.

send

inline fun <T> Connection.send(command: <Error class: unknown class>.() -> T): T

Sends a CDP command and waits for the response.

sleep

open suspend override fun sleep(t: Long)

Suspends the coroutine for a specified time in milliseconds.

toString

open override fun toString(): String

unregisterReconnectRestore

open suspend override fun unregisterReconnectRestore(key: Any)

Removes a restorer previously registered with registerReconnectRestore. No-op if key is not registered.

updateTarget

open suspend override fun updateTarget()

Updates the target information by fetching it from the CDP.

wait

open suspend override fun wait(t: Long?)

Waits until the event listener reports idle (no new events received in a certain timespan). When \`t\` is provided, ensures waiting for \`t\` milliseconds, no matter what.