coroutines-con-kotlin.updates.sharedflow-01-collapsed.kt

val myFlow = MutableStateFlow("Initial Value")
...
val job = launch(Dispatchers.Default) {
    myFlow.collect {
        log("Collected => $it")
    }
}
...
launch {
    listOf(1, 2, 3, 3, 3, 4, 5, 6).forEach {
        log("Updating => $it")
        myFlow.value = "$it"
        delay(300)
    }
    delay(1500)
    job.cancel()
}