SharedFlow.kt

import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.launch

suspend fun main(): Unit = coroutineScope {

    val sharedFLow = MutableSharedFlow<Long>(
        replay = 1,
        extraBufferCapacity = 2
    )

    launch {
        sendUpdates(sharedFLow)
    }

    launch {
        sharedFLow.collect {
            println("Collector 1 Current Time : $it")
        }
    }

    launch {
        delay(4000)
        sharedFLow.collect {
            println("Collector 2 Current Time : $it")
        }
    }

}

suspend fun sendUpdates(sharedFlow: MutableSharedFlow<Long>) {

    repeat(15) {
        delay(200)
        val cTime = System.currentTimeMillis()
        sharedFlow.emit(cTime)
        if(it == 12){
            delay(4000)
        }
    }

}