I have a code which zips two network requests via RxJava:
Single.zip(repository.requestDate(), repository.requestTime()) {
date, time -> Result(date, time)
}
it means that repository.requestDate()
/repository.requestTime()
returns Single<T>
If I want to use Coroutines I need to change requests to:
@GET('link/date')
suspend fun requestDate() : Date
@GET('link/time')
suspend fun requestTime() : Time
But, How can I zip requests via Flow from Kotlin Coroutines?
I know that I can do it like this:
coroutineScope {
val date = repository.requestDate()
val time = repository.requestTime()
Result(date, time)
}
But I want to do it via Flow!
I know about Channels, but Channels.zip()
is deprecated.
val dateFlow = flowOf(repository.requestDate())
val timeFlow = flowOf(repository.requestTime())
val zippedFlow = dateFlow.zip(timeFlow) { date, time -> Result(date, time) }
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/zip.html