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

val myFlow = MutableSharedFlow<String>(replay = 10)
...
val job = launch(Dispatchers.Default) {
    delay(750)
    myFlow
        .onStart {
            log("Collector started collecting...")
        }
        .collect {
            log("Collected => $it")
        }
}
...
launch {
    listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10).forEach {
        log("Emitting => $it")
        myFlow.emit("$it")
        delay(100)
    }
    job.cancel()
}