Kotlin combine

 

fun flowWithCombine() = runBlocking {
    val intFlow = flow<Int> { delay(5000); emit(100)}
    val charFlow = flow<Char> {emit('A'); delay(1000); emit('B')}

    intFlow.combine(charFlow) { num, character ->
        "$num / $character"
    }.collect {
        println(it)
    }
}

// 두 개가 모두 set 되어야 처음 호출 시작.

fun main() {

    flowWithCombine()
}

 

 

출력 :

100 / B