core/dev.kdriver.core.connection/DefaultConnection

DefaultConnection

open class DefaultConnection(websocketUrl: String, messageListeningScope: CoroutineScope, eventsBufferSize: Int, var targetInfo: Target.TargetInfo? = null, var owner: Browser? = null) : Connection

Default implementation of the Connection interface.

Inheritors

DefaultTab

Constructors

DefaultConnection

constructor(websocketUrl: String, messageListeningScope: CoroutineScope, eventsBufferSize: Int, targetInfo: Target.TargetInfo? = null, owner: Browser? = null)

Properties

events

open override val events: Flow<Message.Event>

generatedDomains

open override val generatedDomains: MutableMap<KClass<out Domain>, Domain>

owner

var owner: Browser?

responses

open override val responses: Flow<Message.Response>

targetId

open val targetId: String?

targetInfo

open override var targetInfo: Target.TargetInfo?

type

open val type: String?

Functions

addHandler

inline fun <T> Connection.addHandler(coroutineScope: CoroutineScope, crossinline event: CDP.() -> 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: CommandMode): JsonElement?

Internal method to call a CDP command.

open suspend override fun close()

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

send

inline fun <T> Connection.send(command: CDP.() -> 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

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.