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

val myFlow = MutableSharedFlow<String>(extraBufferCapacity = 3)
...
val job = launch(Dispatchers.Default) {
    delay(700)
    myFlow
        .onStart {
            log("Collector started collecting...")
        }
        .collect {
            log("Collected => $it")
            delay(500)
        }
}
...
launch {
    listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14).forEach {
        log("Emitting => $it")
        myFlow.emit("$it")
        delay(150)
    }
    delay(2000)
    job.cancel()
}