Pacane
04/24/2020, 5:30 PMConflatedBroadcastChannel
) and ideally, one subscriber could unsubscribe without disrupting the other subscribers.bezrukov
04/24/2020, 5:35 PMConflatedBroadcastChannel
🙂 to consume it as flow just use
channel.asFlow()
bezrukov
04/24/2020, 5:41 PMPacane
04/24/2020, 5:42 PMPacane
04/24/2020, 5:43 PMSomeSortOfFlow<T>
to represent initial data + changes over timebezrukov
04/24/2020, 5:43 PMval channel = ConflatedBroadcastChannel()
channel.offer(1)
channel.offer(2)
channel.asFlow().collect {
// what are you expecting there? 1? 2? 1,2?
}
Pacane
04/24/2020, 5:43 PMSomeSortOfFlow<List<T>>
to represent the complete state over timebezrukov
04/24/2020, 5:44 PMPacane
04/24/2020, 5:47 PMcollect
I want to receive 1, 2 but also everything that will eventually be coming after channel.asFlow().collect
Pacane
04/24/2020, 5:49 PMsubscribe()
or whatever method it is, I need to query database to get the whole state, and then over time I want to get the changes individually to do something somewhere else with those changesPacane
04/24/2020, 5:49 PMuli
04/25/2020, 6:24 PMuli
04/25/2020, 6:30 PM