A modern programming language that makes developers happier.

kotlinlang

i am migrating from rxjava to coroutines and just stumped on something now. is there an equivalent to
```local.onErrorResumeNext { remote }```
with coroutines?

Also you can see that onErrorResumeNext exists for Flow, but it’s deprecated and provides replacement it made this way to help users who more familiar with rxjava to find Flow operators

Untitled.kt

so far this is what i have but i know its incomplete

```catch { flowOf(remote) }```
 You need catch { emit(remote) }

What is type of coinLocalDataSource.getCoins().? If it Flow, why you do flowOf(local)

Also what is type of coinRemoteDataSource.getCoins()? Is it just suspend function? If so, you need:
```.catch { emit(coinRemoteDataSource.getCoins()) }```

It’s not good style to have suspend function which returns Flow, I believe you need it only because of getCoins, so you can just move it to catch and it will allow make function not suspend

yeah i am not very familiar with Flow, so that may just be a misuse

this is  `coinLocalDataSource.getCoins()`
```    suspend fun getCoins(): List&lt;CoinEntity&gt; {
        return coinDao.getAllCoins()
    }```

this is `coinRemoteDataSource.getCoins()`
```    suspend fun getCoins() : List&lt;CoinResponse&gt; {
        return coinService.getCoins()
    } ```

btw thank you so much for all of your help

if both of those functions are just suspend, why you even need Flow?

why not rewrite it as simple suspend function:

yep, looks that you just need suspend function
``` suspend fun getCoins(): List&lt;CoinResponse&gt; {
        
          val local = coinLocalDataSource.getCoins()
          return if (local.isEmpty()) {
             coinRemoteDataSource.getCoins()
          } else {
             local
          }.map { it.toResponseModel() }
}```


Only don’t forget that getCoins will not catch exceptions

but what about this piece …

```val remote =
      coinRemoteDataSource.getCoins()
.doOnSuccess {  
   coinLocalDataSource.saveCoins(it.toEntityModels())
}```

```val local = coinLocalDataSource.getCoins()
          return if (local.isEmpty()) {
             val remote = coinRemoteDataSource.getCoins()
             coinLocalDataSource.saveCoins(remote.toEntityModels())
             remote
          } else {
             local
          }.map { it.toResponseModel() }```


i think this is what i need

```suspend fun getCoins(): List&lt;CoinResponse&gt; {
        val local = coinLocalDataSource.getCoins()
        return if (local.isEmpty()) {
            val remote = coinRemoteDataSource.getCoins()
            if(remote.isNotEmpty())
                coinLocalDataSource.saveCoins(remote.toEntityModels())
            remote
        } else {
            local.toResponseModels()
        }
    }```