KtorWebSocketTransport

Default WebSocketTransport backed by a Ktor WebSocket session.

Constructors

constructor(websocketUrl: String)

open override val isActive: Boolean

Whether the underlying connection is currently open.

open suspend override fun close()

Closes the connection.

open suspend override fun connect()

Opens the connection. Must be called before send or incoming. No-op if already open.

open override fun incoming(): Flow<String>

Cold stream of raw text payloads received from the browser. Collecting it starts consuming frames; the flow completes when the connection is closed.

open suspend override fun send(message: String)

Sends a raw text payload to the browser.