Implement Flow use case 1

Author: LukasLechnerDev

app/build.gradle

@@ -37,6 +37,14 @@ android {
         jvmTarget = JavaVersion.VERSION_1_8.toString()
     }
 
+    compileOptions {
+        // Flag to enable support for the new language APIs
+        coreLibraryDesugaringEnabled = true
+        // Sets Java compatibility to Java 8
+        sourceCompatibility = JavaVersion.VERSION_1_8
+        targetCompatibility = JavaVersion.VERSION_1_8
+    }
+
 }
 
 dependencies {
@@ -92,4 +100,6 @@ dependencies {
 
     androidTestImplementation 'androidx.test.ext:junit:1.1.1'
     androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'
+
+    coreLibraryDesugaring("com.android.tools:desugar_jdk_libs:1.1.5")
 }

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/base/UseCase.kt

@@ -171,7 +171,7 @@ private val flowUseCases =
     )
 
 val useCaseCategories = listOf(
-    coroutinesUseCases /*,
-    channelsUseCases,
-    flowUseCases */
+    coroutinesUseCases,
+    // channelsUseCases,
+    flowUseCases
 )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/8-Terminal-flow-operators.kt

@@ -18,5 +18,5 @@ fun main() = runBlocking {
 // Other Terminal operators
 // * toList(), toSet() => collects all of the objects emitted by the Flow and returns them in a List or a Set; works for bounded flows, but not for flows that emit object indefinitely
 // * reduce(), flow
-// * single() => returns first object emitted by the Flow, throws exception if more items are emmited
+// * single() => returns first object emitted by the Flow, throws exception if more items are emitted
 // * first() => returns one object of the flow and then stops consuming; safe to use with a Flow that might return more than one value

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/9-Flows-are-sequential.kt

@@ -20,4 +20,7 @@ fun main() = runBlocking<Unit> {
         }.collect {
             println("Collect $it")
         }
+
+    // every item moves from upstream to downstream
+    // items are NOT all filtered, then mapped, etc
 }

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/sharedFlowAndStateFlow/2-Replay.kt

@@ -9,6 +9,8 @@ import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import kotlin.random.Random
 
+// replay caches emissions of the flow
+
 private fun replaySharedFlow(): Flow<Int> {
     val sharedFlow = MutableSharedFlow<Int>(replay = 2)
 

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/coroutines/usecase1/MockApi.kt

@@ -10,7 +10,7 @@ fun mockApi() =
         MockNetworkInterceptor()
             .mock(
                 "http://localhost/recent-android-versions",
-                Gson().toJson(mockAndroidVersions),
+                { Gson().toJson(mockAndroidVersions) },
                 200,
                 1500
             )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/coroutines/usecase13/MockApi.kt

@@ -8,25 +8,25 @@ fun mockApi() = createMockApi(
     MockNetworkInterceptor()
         .mock(
             "http://localhost/recent-android-versions",
-            Gson().toJson(mockAndroidVersions),
+            { Gson().toJson(mockAndroidVersions) },
             200,
             1000
         )
         .mock(
             "http://localhost/android-version-features/27",
-            Gson().toJson(mockVersionFeaturesOreo),
+            { Gson().toJson(mockVersionFeaturesOreo) },
             MockNetworkInterceptor.INTERNAL_SERVER_ERROR_HTTP_CODE,
             100
         )
         .mock(
             "http://localhost/android-version-features/28",
-            Gson().toJson(mockVersionFeaturesPie),
+            { Gson().toJson(mockVersionFeaturesPie) },
             200,
             1000
         )
         .mock(
             "http://localhost/android-version-features/29",
-            Gson().toJson(mockVersionFeaturesAndroid10),
+            { Gson().toJson(mockVersionFeaturesAndroid10) },
             200,
             1000
         )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/coroutines/usecase14/MockApi.kt

@@ -10,7 +10,7 @@ fun mockApi() =
         MockNetworkInterceptor()
             .mock(
                 "http://localhost/recent-android-versions",
-                Gson().toJson(mockAndroidVersions),
+                { Gson().toJson(mockAndroidVersions) },
                 200,
                 5000
             )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/coroutines/usecase15/AnalyticsWorker.kt

@@ -28,7 +28,7 @@ class AnalyticsWorker(appContext: Context, workerParameters: WorkerParameters) :
             MockNetworkInterceptor()
                 .mock(
                     "http://localhost/analytics/workmanager-screen-opened",
-                    "true",
+                    { "true" },
                     200,
                     1500
                 )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/coroutines/usecase2/MockApi.kt

@@ -10,13 +10,13 @@ fun mockApi() = createMockApi(
     MockNetworkInterceptor()
         .mock(
             "http://localhost/recent-android-versions",
-            Gson().toJson(mockAndroidVersions),
+            { Gson().toJson(mockAndroidVersions) },
             200,
             1500
         )
         .mock(
             "http://localhost/android-version-features/29",
-            Gson().toJson(mockVersionFeaturesAndroid10),
+            { Gson().toJson(mockVersionFeaturesAndroid10) },
             200,
             1500
         )