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

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

fun log(message: String) {
    println("[${Thread.currentThread().name}] : $message")
}

fun main() {
    log("Start")

    val myFlow = MutableSharedFlow<String>(extraBufferCapacity = 3)

    runBlocking {

        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()
        }
    }

    log("End")
}