Remove exception handling code in UseCase2

Author: LukasLechnerDev

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/cancellation/1_cancellation_basics.kt

@@ -0,0 +1,30 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.cancellation
+
+import kotlinx.coroutines.CancellationException
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.flow.onCompletion
+import kotlinx.coroutines.launch
+import kotlin.coroutines.EmptyCoroutineContext
+
+suspend fun main() {
+    val scope = CoroutineScope(EmptyCoroutineContext)
+
+    scope.launch {
+        intFlow()
+            .onCompletion { throwable ->
+                if (throwable is CancellationException) {
+                    println("Flow got cancelled.")
+                }
+            }
+            .collect {
+                println("Collected $it")
+            }
+    }.join()
+}
+
+private fun intFlow() = flow {
+    emit(1)
+    emit(2)
+    emit(3)
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/FlowUseCase2ViewModel.kt

@@ -69,9 +69,5 @@ class FlowUseCase2ViewModel(
         .onStart {
             emit(UiState.Loading)
         }
-        .catch { throwable ->
-            Timber.tag("Flow").d("Handle exception in catch operator $throwable")
-            emit(UiState.Error("Something went wrong..."))
-        }
         .asLiveData(defaultDispatcher)
 }

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/StockPriceDataSource.kt

@@ -5,8 +5,6 @@ import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.Stock
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
-import kotlinx.coroutines.flow.retry
-import retrofit2.HttpException
 import timber.log.Timber
 
 interface StockPriceDataSource {
@@ -22,14 +20,5 @@ class NetworkStockPriceDataSource(mockApi: FlowMockApi) : StockPriceDataSource {
             emit(currentStockList)
             delay(5_000)
         }
-    }.retry { cause ->
-        Timber.tag("Flow").d("Enter retry operator with $cause")
-        val shouldRetry = cause is HttpException
-
-        if (shouldRetry) {
-            delay(5_000)
-        }
-
-        shouldRetry
     }
 }