0

我有这个combinelatest flowable:

private val subject: BehaviorSubject<Int> = BehaviorSubject.create()

Flowable.combineLatest(
    materialA, 
    materialB, 
    subject.toFlowable(LATEST), 
    Function3 { ma, mb, index -> if(index == 0) ... else if(index ==1) ... else ... }  

subject.onNext(99)

基本上,我想观察这两种材料的数据库变化,并将它们结合起来向用户展示一些数据。有时,我需要使用最新的输出,并进行不同的组合(计算繁重)。这就是为什么我制作indexcombinelatest. 这是一种有效的方法还是有更好的选择?

PS。我需要能够随时要求不同的组合(那是我没有使用 Flowable.just()),并且我想避免在 obs 链之外保存状态。

4

0 回答 0