collectors

jeorg-kotlin-coroutines/coroutines-crums-group-1/src/main/kotlin/org/jesperancinha/ktd/Main.kt

@@ -17,5 +17,6 @@ object Main {
         org.jesperancinha.ktd.java.ValidationUsersEmail.main(emptyArray())
         CancellingCounterCoroutines.main()
         RunningFold.main()
+        TicketCollectors.main()
     }
 }

jeorg-kotlin-coroutines/coroutines-crums-group-1/src/main/kotlin/org/jesperancinha/ktd/TicketCollectors.kt

@@ -0,0 +1,42 @@
+package org.jesperancinha.ktd
+
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.collectLatest
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.runBlocking
+import kotlin.random.Random
+
+class TicketCollectors {
+    companion object {
+        @JvmStatic
+        fun main(args: Array<String> = emptyArray()) = runBlocking {
+            flow {
+                repeat(10) {
+                    emit(Random.nextInt(10, 25))
+                    delay(2)
+                }
+            }.collect { value ->
+                processTemperature(value)
+            }
+            println("Finished processing collect!")
+
+            flow {
+                repeat(10) {
+                    emit(Random.nextInt(10, 25))
+                    delay(2)
+                }
+            }.collectLatest { value ->
+                processTemperature(value)
+            }
+            println("Finished processing collectLatest!")
+
+        }
+
+        private suspend fun processTemperature(value: Int) {
+            println("Processing-> $value")
+            delay(Random.nextLong(1, 3))
+            println("Processed!-> $value")
+
+        }
+    }
+}