catchAndReturn

Author: hoc081098

buildSrc/src/main/kotlin/deps.kt

@@ -70,7 +70,7 @@ object deps {
 
   const val coil = "io.coil-kt:coil:2.6.0"
   const val viewBindingDelegate = "com.github.hoc081098:ViewBindingDelegate:1.4.0"
-  const val flowExt = "io.github.hoc081098:FlowExt:0.8.0"
+  const val flowExt = "io.github.hoc081098:FlowExt:0.8.1-Beta"
   const val timber = "com.jakewharton.timber:timber:5.0.1"
 
   object arrow {

data/src/main/java/com/hoc/flowmvi/data/UserRepositoryImpl.kt

@@ -16,6 +16,7 @@ import com.hoc.flowmvi.domain.model.User
 import com.hoc.flowmvi.domain.model.UserError
 import com.hoc.flowmvi.domain.model.UserValidationError
 import com.hoc.flowmvi.domain.repository.UserRepository
+import com.hoc081098.flowext.catchAndReturn
 import com.hoc081098.flowext.flowFromSuspend
 import com.hoc081098.flowext.retryWithExponentialBackoff
 import com.hoc081098.flowext.scanWith
@@ -25,7 +26,6 @@ import kotlin.time.ExperimentalTime
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.flow.MutableSharedFlow
-import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.onEach
@@ -90,9 +90,9 @@ internal class UserRepositoryImpl(
         }
       }.onEach { Timber.d("[USER_REPO] Emit users.size=${it.size} ") }
       .map { it.right().leftWiden<UserError, _, _>() }
-      .catch {
+      .catchAndReturn {
         logError(it, "getUsers")
-        emit(errorMapper(it).left())
+        errorMapper(it).left()
       }
 
   override suspend fun refresh() =