Code after 'sharedflows are hot' lecture

Author: LukasLechnerDev

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/hot_and_cold_flows/1-flows_are_cold.kt

@@ -3,25 +3,34 @@ package com.lukaslechner.coroutineusecasesonandroid.playground.flow.hot_and_cold
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.flow
-import kotlinx.coroutines.flow.onEach
+import kotlinx.coroutines.launch
 
 fun coldFlow() = flow {
     println("Emitting 1")
     emit(1)
 
+    delay(1000)
     println("Emitting 2")
     emit(2)
 
+    delay(1000)
     println("Emitting 3")
     emit(3)
-}.onEach {
-    delay(1000)
 }
 
 suspend fun main(): Unit = coroutineScope {
 
-    coldFlow()
-        .collect {
-            println("Collector 1 collects: $it")
-        }
+    launch {
+        coldFlow()
+            .collect {
+                println("Collector 1 collects: $it")
+            }
+    }
+
+    launch {
+        coldFlow()
+            .collect {
+                println("Collector 2 collects: $it")
+            }
+    }
 }

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/hot_and_cold_flows/2_sharedflows_are_hot.kt

@@ -0,0 +1,36 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.hot_and_cold_flows
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.launch
+
+fun main() {
+
+    val sharedFlow = MutableSharedFlow<Int>()
+
+    val scope = CoroutineScope(Dispatchers.Default)
+
+    scope.launch {
+        repeat(5) {
+            println("SharedFlow emits $it")
+            sharedFlow.emit(it)
+            delay(200)
+        }
+    }
+
+    scope.launch {
+        sharedFlow.collect{
+            println("Collected $it in collector 1")
+        }
+    }
+
+    scope.launch {
+        sharedFlow.collect{
+            println("Collected $it in collector 2")
+        }
+    }
+
+    Thread.sleep(1500)
+}