[Question]: I'm having trouble getting realtime flow of updates to work

[aaronbond]

Wondering how to get real time working

quick code snippet:

    private val channel = client.realtime.createChannel("channelId")
    private val messageFlow: Flow<PostgresAction.Insert> = channel.postgresChangeFlow(schemaName) {
        table = messageTableName
    }

    val newMessageFlow: Flow<Message> =
        messageFlow.map {
            it.decodeRecord<ReceiveMessage>()
        }.map { Message(it.content, true) }

    suspend fun init() {
        client.realtime.connect()
        channel.join()
    }

i'm inserting new rows, and putting a breakpoint on it.decodeRecord() but not seeing anything happen. quite new to this so i assume it's probably use error.

[jan-tennert]

Did you enable replication for the corresponding table?

https://supabase.com/docs/guides/database/replication

[jan-tennert]

Also do you collect the actual flow? If not, no data gets passed through. (Learn more here)

[aaronbond]

yes, replication is enabled and i'm collecting the flow.

I will have a play around with it but if there are no other common issues i'm a bit stumped. I'm trying it on compose desktop if that's relevant. I will look into it further.

[jan-tennert]

In Compose you can collect flows as a State using val products by flow.collectAsState(default)
or if you use something like a ViewModel

flow
  .onEach { proccess(it) 
  .launchIn(viewModelScope)

or just collect the flow in a coroutine

[brezinajn]

Had a similar issue few times. You can try restarting the project on Supabase.

[jan-tennert]

yes, replication is enabled and i'm collecting the flow.

I will have a play around with it but if there are no other common issues i'm a bit stumped. I'm trying it on compose desktop if that's relevant. I will look into it further.

There is now a full demo available which uses Compose Multiplatform.

[jan-tennert]

Closing due to inactivity. Feel free to reopen this issue, if you need further help.