我想压缩 Observable<List<Int>>
的列表.
fun testObservablezip() {
val jobs = mutableListOf<Observable<List<Int>>>()
for (i in 0 until 100 step 10) {
val job = Observable.fromArray(listOf(i + 1, i + 2, i + 3))
jobs.add(job)
}
val listMerger = Function<Array<List<Int>>, List<Int>> { it.flatMap { it } }
Observable.zip(jobs, listMerger) // No valid function parameters
}
尽管 listMerger
已定义其输入和输出,zip
不接受。
最佳答案
zip
的函数在 RxJava 中定义为 Function<? super Object[], R>
所以你必须指定一个对象数组,而不是 List<Int>
数组,然后将对象数组元素转换回 List<Int>
:
import io.reactivex.Observable
import io.reactivex.functions.Function;
fun testObservablezip() {
val jobs = mutableListOf<Observable<List<Int>>>()
for (i in 0 until 100 step 10) {
val job = Observable.fromArray(listOf(i + 1, i + 2, i + 3))
jobs.add(job)
}
val listMerger = Function<Array<Any>, List<Int>> {
it.flatMap { it as List<Int> } }
Observable.zip(jobs, listMerger) // No valid function parameters
}
关于kotlin - RxJava Zip 可观察可迭代,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50423572/