输入自己的值来组合最新
我有这个最好的流动性:
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
作为一个来源。 这是一个有效的方法,还是有更好的选择?
PS。 我需要能够随时要求一个不同的组合(这是我没有使用Flowable.just()),我想避免保存在obs链之外的状态。
- 如何有条件地在RxJava流中添加一个异步操作?
- 不能解决“内容长度和流长不一致”的错误
- 在Kotlin Android中处理多个函数中的可变变量
- let的用法还有,如果在Kotlin中取不用的话?
- 不能从java模块调用kotlin模块
- ArrayAdapter.clear kotlin
- 使用kotlin&greendao的Android Studio 3.0 Proguard将返回ClassLookupException
- Anko日志与详细和调试不起作用
- 错误:将字节码转换为dex时出错:原因:com.android.dex.DexException:多个dex文件定义了Lorg / jetbrains / anko / collections / CollectionsKt;