Hi, i am using sqldelight to get data from databas...

# coroutines

[brabo-hi]

Hi, i am using sqldelight to get data from database as flow, however the flow is not being collected whenever a new item is added

val players: Flow<List<HockeyPlayer>> = 
  playerQueries.selectAll()
    .asFlow()
    .mapToList()

players,collect{
   // i am not getting new list when item is added, i only receive data once
}

What could i be doing that is not right ?

[Richard Gomez]

I suppose it depends on how SqlDelight has implemented the asFlow() function.

Given that flows are 'cold', not 'hot' like channels, it's likely that the flow terminates once the first iteration of data is collected.

https://elizarov.medium.com/cold-flows-hot-channels-d74769805f9

[brabo-hi]

i am checking `

onCompletion {}

`
but it never fires

[Tiago Nunes]

Hi! Can you show the whole snippet where you’re calling players.collect?

[Tiago Nunes]

If you are calling 2 terminal operator in the same coroutine, only the first one is ever called. Maybe that’s your case

[Tiago Nunes]

I’m using SQLDelight and their FlowExtensions, everything works great

[Tiago Nunes]

Another thing that could be happening is: you might be listening to the query in a different Database instance than you are updating it

[brabo-hi]

@Tiago Nunes i am definitely reading and update from two different database instances, let me fix it to see

[Tiago Nunes]

When you call asFlow, it registers a query listener in the database instance. When there are updates, all registered listeners in the database instance are notified. It needs to be the same db instance to trigger the flow

[brabo-hi]

@Tiago Nunes thanks i just got it working, you are right, i was using different instances. Thanks a lot