1）下面的代码无法编译并出现错误：“没有足够的信息来推断类型变量R”
keywordChanges
.withLatestFrom(searchParamsSubject)
.subscribe { (keyword, searchParams) ->
...
}
2）下面的代码可以编译和运行，但是我希望不要空subscribe()并且不要在合并器函数中添加副作用。
keywordChanges
.withLatestFrom(searchParamsSubject) { keyword, searchParams ->
searchParamsSubject.onNext(searchParams.copy(keyword = keyword))
}
.subscribe()
3）下面是我试图在1）中调用的RxKotlin库中的代码
/**
* Emits a `Pair`
*/
inline fun <T, U, R> Observable<T>.withLatestFrom(other: ObservableSource<U>): Observable<Pair<T,U>>
= withLatestFrom(other, BiFunction{ t, u -> Pair(t,u) }
您必须明确告诉编译器正在使用哪些类。
val o1 = Observable.just(1)
val o2 = Observable.just(2)
o1.withLatestFrom(o2, BiFunction { t1 : Int, t2 : Int -> t1 to t2})
.subscribe { (one, two) -> }
另外，RxKotlin扩展功能库可以为您处理此问题。https://github.com/ReactiveX/RxKotlin
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句