example_stateflow.kt

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

fun main() = runBlocking {
    val stateFlow = MutableStateFlow<Int>(0)

    // Observe values
    val job = launch {
        stateFlow.collect {
            print("$it ")
        }
    }

    // Change values
    (1..5).forEach {
        delay(500)
        stateFlow.value = it
    }

    // Cancel running job
    job.cancel()
    job.join()
}