混淆使用Kotlin和rx-java combineLatest的表单验证

Question

因此，我想使用rx 2进行表单验证。我在用Kotlin。我遇到了两个问题。emailObservable和passwordObservable都是Disposable!型。我试图通过调用val emailObservable: Observable<Boolean>来指定类型，但是Android认为是它的Disposable!。

其次，当我想使用combineLatest方法时，我得到了一个错误:不能用提供的参数调用以下函数。

emailObservable和passwordObservable都能正常工作。我刚接触过rx，对这种类型的东西很困惑。

val emailObservable = RxTextView.afterTextChangeEvents(textEmail)
                .observeOn(AndroidSchedulers.mainThread())
                .map { x -> textEmail.text.length > 3 }
                .subscribe { x -> foo(x) }

val passwordObservable =RxTextView.afterTextChangeEvents(textPassword)
                .observeOn(AndroidSchedulers.mainThread())
                .map { x -> textPassword.text.length > 5 }
                .subscribe { x -> foo(x) }


Observable.combineLatest(emailObservable,
passwordObservable,
BiFunction { x: Boolean, y:Boolean -> x && y })

Answer 1

实际上，关于Disposable和Observable，编译器/IDE是正确的。subscribe方法在Observable上被调用并返回一个Disposable，也就是说，您可以在Observable完成之前从Observable中取消订阅(类似于"cancel")。

然后，当您提供两个combineLatest s时，希望用两个Observables调用该方法。要解决这个问题，不应该直接调用链中的subscribe，而应该根据combineLatest的结果调用。

示例：

fun main(args: Array<String>) {
    val first = Observable.intervalRange(1, 10, 0, 2, TimeUnit.SECONDS)
    val second = Observable.intervalRange(10, 20, 0, 1, TimeUnit.SECONDS)

    Observable.combineLatest(arrayOf(first, second)) {
        "${it[0]} -> ${it[1]}"
    }.blockingSubscribe() {
        println(it)
    }
}

输出：

1 -> 10
1 -> 11
2 -> 11
2 -> 12
2 -> 13
...