realtime-kt/io.github.jan.supabase.realtime.websocket/KtorRealtimeWebsocket

KtorRealtimeWebsocket

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

Implementation of RealtimeWebsocket using Ktor's DefaultClientWebSocketSession.

Constructors

KtorRealtimeWebsocket

constructor(ws: DefaultClientWebSocketSession)

Properties

hasIncomingMessages

open override val hasIncomingMessages: Boolean

Whether there are incoming messages that can be received.

Functions

blockUntilDisconnect

open suspend override fun blockUntilDisconnect()

Block the current coroutine until the websocket is disconnected.

open override fun disconnect()

Disconnect the websocket.

open suspend override fun receive(): RealtimeMessage

Receive a message from the websocket.

open suspend override fun send(message: RealtimeMessage)

Send a message to the websocket.