genovich
10/13/2020, 2:00 PMraulraja
10/13/2020, 9:29 PMraulraja
10/13/2020, 9:29 PMraulraja
10/13/2020, 9:30 PMraulraja
10/13/2020, 9:30 PMraulraja
10/13/2020, 9:31 PMsimon.vergauwen
10/14/2020, 8:49 AMgenovich
10/14/2020, 10:39 AMsimon.vergauwen
10/14/2020, 11:44 AMraulraja
10/14/2020, 11:52 AMgenovich
02/27/2021, 2:16 PMsimon.vergauwen
03/01/2021, 8:05 AMIO
, https://github.com/arrow-kt/arrow/tree/master/arrow-docs/docs/io.
For Single
, and Observable
pretty much the same principles apply but we recommend to use the official KotlinX Coroutines RxJava module to interopt.
https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-rx2
And then you can do something like this.
object Data
suspend fetchData(): Data = TODO()
val res: Single<Pair<Data, Data>> = rxSingle {
parMapN({ fetchData() }, { fetchData() }, ::Pair)
}