android rxjava2 zip 可变参数

Question

我现在正在研究 android kotlin 中的 rxjava2。并尝试编写一个函数来压缩多个 observable 和 observer。但这似乎有些错误。谁能帮忙？首先，我尝试编写 zip 2 observable 并且它有效。但是当我想将它扩展到 vararg 时，它失败了。

fun <T> ApiSubscribeZip2(observable1: Observable<T>, observable2: Observable<T>, observer: Observer<List<T>>) {
    Observable.zip(observable1, observable2, BiFunction<T, T, List<T>> { t1: T, t2: T ->
        zipAdd(t1, t2)
    })
        ?.subscribeOn(Schedulers.io())?.unsubscribeOn(Schedulers.io())?.observeOn(AndroidSchedulers.mainThread())
        ?.subscribe(observer as Observer<in List<T>>)
}

fun <T> ApiSubscribeZipN(vararg observable: Observable<T>?, observer: Observer<List<T>>) {
    Observable.zip(observable, Function<T, List<T>> { it ->
        zipAdd(it)

    })
}

private fun <T> zipAdd(vararg observableType: T): List<T> {
    val list = ArrayList<T>()
    for (ob in observableType) {
        list.add(ob)
    }
    return list
}

apisubscribezipN 显示 None 可以使用提供的参数调用以下函数。

Answer 1

您可以这样使用 Observable.zipIterable：

fun <T> ApiSubscribeZipN(vararg observable: Observable<T>?, observer: Observer<List<T>>) {
    Observable.zipIterable<T, List<T>>(observable.filterNotNull().toList(), { it.toList() as List<T>? }, false, 100)
        .subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.io())
        .subscribe(observer)
}

Answer 2

这个呢？

import io.reactivex.Observable
import io.reactivex.functions.Function
import org.junit.Test

fun <T> apiSubscribeZipN(vararg observable: Observable<T>?): Observable<List<T>> {
    val filterNotNull = observable.filterNotNull()
    return Observable.zip(filterNotNull, Function { inArr ->
        inArr.map {
            it as T
        }
    })
}

测试

@Test
fun whatever() {
    val mergeWith1 = Observable.fromArray("test11", "test12").mergeWith(Observable.never())
    val mergeWith2 = Observable.fromArray("test21", "test22").mergeWith(Observable.never())

    apiSubscribeZipN(mergeWith1, mergeWith2)
        .test()
        .assertValues(listOf("test11", "test21"), listOf("test12", "test22"))
}

android rxjava2 zip 可变参数

android rxjava2 zip vararg parameter

zip

android

kotlin

rx-java2