RealtimeGatewaySession

Handle to a single open realtime session.

The session is responsible for transport lifecycle and event framing only. Consumers send typed ClientRealtimeEvents and observe a Flow of raw provider events; the broker layer normalises raw events into the vendor-neutral RealtimeEvent union.

Properties

Link copied to clipboard
abstract val rawEvents: Flow<JsonObject>

Cold flow of raw provider events, one element per server message.

Functions

Link copied to clipboard
abstract suspend fun close()

Close the session and tear down the underlying transport.

Link copied to clipboard
abstract suspend fun send(event: ClientRealtimeEvent)

Send a typed client event into the session.