Sends a message to everyone who joined the channel. Can be used even if you aren't connected to the channel. Requires Realtime.Config.vsn to be set to RealtimeProtocolVersion.V2

broadcastFlow

abstract fun broadcastFlow(event: String): Flow<RealtimeBroadcast>

Broadcasts can be messages sent by other clients within the same channel under a specific event.

broadcastFlow

inline fun <T : Any> RealtimeChannel.broadcastFlow(event: String): Flow<T>

Broadcasts can be messages sent by other clients within the same channel under a specific event.

currentPresences

inline fun <Data> RealtimeChannel.currentPresences(ignoreOtherTypes: Boolean = true): List<Data>

Returns the current presences as a typed list. This is a snapshot of all currently tracked presences in the channel, deserialized as Data.

httpSend

abstract suspend fun httpSend(event: String, payload: BroadcastPayload, builder: HttpSendBuilder.() -> Unit = {})

Sends a broadcast message explicitly via REST API.

httpSend

inline suspend fun <T> RealtimeChannel.httpSend(event: String, payload: T, noinline builder: HttpSendBuilder.() -> Unit = {})

Sends a broadcast message explicitly via REST API.

postgresChangeFlow

inline fun <T : PostgresAction> RealtimeChannel.postgresChangeFlow(schema: String, noinline filter: PostgresChangeFilter.() -> Unit = {}): Flow<T>

Listen for postgres changes in a channel.

postgresChangeFlowInternal

abstract fun <T : PostgresAction> RealtimeChannel.postgresChangeFlowInternal(action: KClass<T>, schema: String, filter: PostgresChangeFilter.() -> Unit = {}): Flow<T>

Non-inline variant of postgresChangeFlow for implementation and mocking purposes

postgresListDataFlow

inline fun <Data : Any> RealtimeChannel.postgresListDataFlow(schema: String = "public", table: String, filter: FilterOperation? = null, primaryKey: PrimaryKey<Data>): Flow<List<Data>>

inline fun <Data : Any> RealtimeChannel.postgresListDataFlow(schema: String = "public", table: String, filter: FilterOperation? = null, primaryKeys: List<PrimaryKey<Data>>): Flow<List<Data>>

@JvmName(name = "postgresListDataFlowMultiplePks")

inline fun <Data : Any, Value> RealtimeChannel.postgresListDataFlow(schema: String = "public", table: String, filter: FilterOperation? = null, primaryKeys: List<KProperty1<Data, Value>>): Flow<List<Data>>

inline fun <Data : Any, Value> RealtimeChannel.postgresListDataFlow(schema: String = "public", table: String, filter: FilterOperation? = null, primaryKey: KProperty1<Data, Value>): Flow<List<Data>>

This function retrieves the initial data from the table and then listens for changes. It automatically handles inserts, updates and deletes.

postgresSingleDataFlow

inline suspend fun <Data : Any> RealtimeChannel.postgresSingleDataFlow(schema: String = "public", table: String, primaryKey: PrimaryKey<Data>, crossinline filter: PostgrestFilterBuilder.() -> Unit): Flow<Data>

inline suspend fun <Data, Value> RealtimeChannel.postgresSingleDataFlow(schema: String = "public", table: String, primaryKey: KProperty1<Data, Value>, crossinline filter: PostgrestFilterBuilder.() -> Unit): Flow<Data>

This function retrieves the initial data for a single value and then listens for changes on that value. It automatically handles updates and closes the flow on the delete event.

presenceChangeFlow

abstract fun presenceChangeFlow(): Flow<PresenceAction>

Listen for clients joining / leaving the channel using presences

presenceDataFlow

inline fun <Data> RealtimeChannel.presenceDataFlow(): Flow<List<Data>>

Listens for presence changes and caches the presences based on their keys. This function automatically handles joins and leaves.

removePostgresChange

abstract fun RealtimeChannel.removePostgresChange(data: PostgresJoinConfig)

scheduleRejoin

abstract suspend fun scheduleRejoin()

abstract suspend fun subscribe(blockUntilSubscribed: Boolean = false)

Subscribes to the channel

teardown

abstract fun teardown()

track

abstract suspend fun track(state: JsonObject)

Store an object in your presence's state. Other clients can get this data when you either join or leave the channel. Use this method again to update the state.

track

inline suspend fun <T : Any> RealtimeChannel.track(state: T)

Store an object in your presence's state. Other clients can get this data when you either join or leave the channel. Use this method again to update the state.

unsubscribe

abstract suspend fun unsubscribe()

Unsubscribes from the channel

untrack

abstract suspend fun untrack()

Removes the object from your presence's state

updateAuth

abstract suspend fun updateAuth(jwt: String?)

Updates the JWT token for this channel

updateStatus

abstract fun updateStatus(status: RealtimeChannel.Status)