uuidFlow.kt

fun main() {
    runBlocking {
        uuidFlow().collect{ log(it.toString()) }
    }
}

fun uuidFlow(): Flow<UUID> = flow {
    while (true) {
        delay(100)
        emit(UUID.randomUUID())
    }
}

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