Add playground files for collectLatest and mapLatest

Author: LukasLechnerDev

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/6_collect_latest.kt

@@ -0,0 +1,25 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.collectLatest
+import kotlinx.coroutines.flow.flow
+
+suspend fun main() = coroutineScope {
+
+ val flow = flow {
+ repeat(5) {
+ val pancakeIndex = it + 1
+ println("Emitter: Start Cooking Pancake $pancakeIndex")
+ delay(100)
+ println("Emitter: Pancake $pancakeIndex ready!")
+ emit(pancakeIndex)
+ }
+ }
+
+ flow.collectLatest {
+ println("Collector: Start eating pancake $it")
+ delay(300)
+ println("Collector: Finished eating pancake $it")
+ }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/7_map_latest.kt

@@ -0,0 +1,29 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.flow.mapLatest
+
+suspend fun main() = coroutineScope {
+
+ val flow = flow {
+ repeat(5) {
+ val pancakeIndex = it + 1
+ println("Emitter: Start Cooking Pancake $pancakeIndex")
+ delay(100)
+ println("Emitter: Pancake $pancakeIndex ready!")
+ emit(pancakeIndex)
+ }
+ }.mapLatest {
+ println("Add topping onto the pancake $it")
+ delay(200)
+ it
+ }
+
+ flow.collect {
+ println("Collector: Start eating pancake $it")
+ delay(300)
+ println("Collector: Finished eating pancake $it")
+ }
+}