Add playground files for buffers in SharedFlows and StateFlows

Author: LukasLechnerDev

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/10_buffer_in_stateflow.kt

@@ -0,0 +1,38 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.launch
+import kotlin.system.measureTimeMillis
+
+suspend fun main(): Unit = coroutineScope {
+
+    val flow = MutableStateFlow(0)
+
+    // Collector 1
+    launch {
+        flow.collect {
+            println("Collector 1 processes $it")
+        }
+    }
+
+    // Collector 2
+    launch {
+        flow.collect {
+            println("Collector 2 processes $it")
+            delay(100)
+        }
+    }
+
+    // Emitter
+    launch {
+        val timeToEmit = measureTimeMillis {
+            repeat(5) {
+                flow.emit(it)
+                delay(10)
+            }
+        }
+        println("Time to emit all values: $timeToEmit ms")
+    }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/9_buffer_in_sharedflow.kt

@@ -8,7 +8,7 @@ import kotlin.system.measureTimeMillis
 
 suspend fun main(): Unit = coroutineScope {
 
-    val flow = MutableSharedFlow<Int>()
+    val flow = MutableSharedFlow<Int>(extraBufferCapacity = 10)
 
     // Collector 1
     launch {
@@ -17,6 +17,14 @@ suspend fun main(): Unit = coroutineScope {
         }
     }
 
+    // Collector 2
+    launch {
+        flow.collect {
+            println("Collector 2 processes $it")
+            delay(100)
+        }
+    }
+
     // Emitter
     launch {
         val timeToEmit = measureTimeMillis {