race_example.kt

@ExperimentalCoroutinesApi
public fun <T> race(flows: Iterable<Flow<T>>): Flow<T> = TODO("Will implement")

fun firstSource(): Flow<String> = flow {
    delay(400)
    repeat(10) {
        emit("[1] - $it")
        delay(100)
    }
}

fun secondSource(): Flow<String> = flow {
    delay(100)
    repeat(10) {
        emit("[2] - $it")
        delay(100)
    }
}

fun thirdSource(): Flow<String> = flow {
    delay(500)
    repeat(10) {
        emit("[3] - $it")
        delay(100)
    }
}


suspend fun main() {
    race(
        firstSource(),
        secondSource(),
        thirdSource()
    ).collect { println(it) }
    // CONSOLE    
    // [2] - 0
    // [2] - 1
    // [2] - 2
    // [2] - 3
    // [2] - 4
    // [2] - 5
    // [2] - 6
    // [2] - 7
    // [2] - 8
    // [2] - 9
}