Add playground files for buffer overflows

Author: LukasLechnerDev

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/2_buffer_overflow_suspend.kt

@@ -0,0 +1,26 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.buffer
+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)
+        }
+    }.buffer(capacity = 1, onBufferOverflow = BufferOverflow.SUSPEND)
+
+    flow.collect {
+        println("Collector:  Start eating pancake $it")
+        delay(300)
+        println("Collector:  Finished eating pancake $it")
+    }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/3_buffer_overflow_drop_oldest.kt

@@ -0,0 +1,26 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.buffer
+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)
+        }
+    }.buffer(capacity = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
+
+    flow.collect {
+        println("Collector:  Start eating pancake $it")
+        delay(300)
+        println("Collector:  Finished eating pancake $it")
+    }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/4_buffer_overflow_drop_latest.kt

@@ -0,0 +1,26 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.buffer
+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)
+        }
+    }.buffer(capacity = 1, onBufferOverflow = BufferOverflow.DROP_LATEST)
+
+    flow.collect {
+        println("Collector:  Start eating pancake $it")
+        delay(300)
+        println("Collector:  Finished eating pancake $it")
+    }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/playground/flow/concurrency/5_buffer_unlimited_size.kt

@@ -0,0 +1,26 @@
+package com.lukaslechner.coroutineusecasesonandroid.playground.flow.concurrency
+
+import kotlinx.coroutines.channels.Channel.Factory.UNLIMITED
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.buffer
+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)
+        }
+    }.buffer(capacity = UNLIMITED)
+
+    flow.collect {
+        println("Collector:  Start eating pancake $it")
+        delay(300)
+        println("Collector:  Finished eating pancake $it")
+    }
+}