Combine a Flow and a non Flow api response Kotlin

user_1516954 0
Viewed 227

I currently have a piece of logic as follows:

interface anotherRepository {
      fun getThings():  Flow<List<String>>
}

interface repository {
    suspend fun getSomeThings(): AsyncResult<SomeThings>
}

when (val result = repository.getSomeThings()) {
            is AsyncResult.Success -> {
                anotherRepository.getThings().collectLatest {
                    // update the state
                }
                else -> { }
            }
        }

The problem I am having is that, if repository.getSomeThings has been triggered multiple times before, anotherRepository.getThings is getting triggered for the amount of all the pre-loaded values from repository.getSomeThings. I was wondering what is the proper way to use these repositories, one a suspend function, the other a Flow together. The equivalent behaviour that is combineLatest{} in Rx.

Thank you.

kotlin-flow kotlin-coroutines kotlin
1 Answers

There are a couple of ways to solve your problem. One way is just to call repository.getSomeThings() in the collectLatest block and cache last result:

var lastResult: AsyncResult<SomeThings>? = null

anotherRepository.getThings().collectLatest {
    if (lastResult == null) {
        lastResult = repository.getSomeThings()
    }
    // use lastResult and List<String>
}

Another approach is to create a Flow, which will be calling repository.getSomeThings() function, and combine two Flows:

combine(
  anotherRepository.getThings(),
  flow {emit(repository.getSomeThings())}
) { result1: List<String>, result2: AsyncResult<SomeThings>  ->
  ...
}
user_17316260
Related