mgrazianodecastro
01/30/2023, 7:34 PMfun main() = runBlocking {
val numbersFlow = flowOf(1,2,3).onEach { delay(1000) }
val lettersFlow = flowOf("A", "B","C").onEach { delay(2000) }
numbersFlow.combine(lettersFlow) { number, letter ->
"$number - $letter"
}.collect {
println(it)
}
}
// 1 - A
// 2 - A
// 3 - A
// 3 - B
// 3 - C
ephemient
01/30/2023, 7:41 PMnumbersFlow.onStart { emit(null) }.combine(
lettersFlow.onStart { emit(null) }
) { number, letter ->
...
}
mkrussel
01/30/2023, 7:41 PMmgrazianodecastro
01/30/2023, 7:42 PMnull - null
1 - null
2 - null
2 - A
3 - A
3 - B
3 - C