我有这个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)
基本上,我想观察这两种材料的数据库变化,并将它们结合起来向用户展示一些数据。有时,我需要使用最新的输出,并进行不同的组合(计算繁重)。这就是为什么我制作index
了combinelatest
. 这是一种有效的方法还是有更好的选择?
PS。我需要能够随时要求不同的组合(那是我没有使用 Flowable.just()),并且我想避免在 obs 链之外保存状态。