KtorRealtimeWebsocket

class KtorRealtimeWebsocket(ws: DefaultClientWebSocketSession) : RealtimeWebsocket(source)

Implementation of RealtimeWebsocket using Ktor's DefaultClientWebSocketSession.

Constructors

constructor(ws: DefaultClientWebSocketSession)

Whether there are incoming messages that can be received.

open suspend override fun blockUntilDisconnect()

Block the current coroutine until the websocket is disconnected.

open override fun disconnect()

Disconnect the websocket.

open override fun makeRef(): String

Generates a new ref for a realtime message

open suspend override fun receive(): Frame

Receive a frame from the websocket.

open suspend override fun send(data: ByteArray)

Sends a binary message to the websocket.

open suspend override fun send(message: RealtimeMessage, vsn: RealtimeProtocolVersion)

Send a message to the websocket.