I am trying to create a moving window of data using Kotlin Flows. It can be achieved in RxKotlin using a buffer, but buffer is not the same using Flows. RxKotlin has a buffer operator, periodically...

I've one LiveData named sortOrder and then I've another variable named myData that observes any change to sortOrder and populates data accordingly. class TestViewModel @ViewModelInject constructor(...

I notice a strange behavior when trying to prematurely cancel from a Flow. Take a look at the following example. This is a simple flow that emits integer values private fun createFlow() = flow {...

In the last Google I/O, Jose Alcerreca and Yigit Boyar told us that we should no longer use LiveData to fetch data. Now we should use suspend functions for one-shot fetches and use Kotlin's Flow to...

I wanted to know how can I send/emit items to a Kotlin.Flow, so my use case is: In the consumer/ViewModel/Presenter I can subscribe with the collect function: fun observe() { coroutineScope.laun...

I'm trying to deliver realtime updates to my view with Kotlin Flows and Firebase. This is how I collect my realtime data from my ViewModel: class MainViewModel(repo: IRepo): ViewModel() { val f...

I'm replacing my current implementation using RxJava to Coroutines and Flow. I'm having some trouble using some Flow operators. I'm trying to filter the list of items inside a Flow before providin...

I am trying to migrate from LiveData to Flow in my Room Dao. App is working fine, but I have problems with testing behavior. When I run the test it is starting and running indefinately. I also trie...