如何使用另一个可观察的 rx kotlin 的结果过滤可观察对象发出的列表?

Question

假设我有一个数字列表和可观察的来源，它可以评估该列表中的每个数字。(需要使用以下方法。它们是我必须使用的API的一部分(

fun getNumberListSource() : Observable<List<Int>> {...}
fun getOddChecker(value: Int): Observable<Boolean> {...}

让我们说源可能看起来像这样：

class NumberSource {
private val source = BehaviorSubject.create<List<Int>>()
fun getNumberListSource(): Observable<List<Int>> = source.doOnNext { println("doOnNext :)") }
fun start(){
Thread {
Thread.sleep(1000)
source.onNext(listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12))
Thread.sleep(1000)
source.onNext(listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12))
Thread.sleep(1000)
source.onComplete()
}.start()
}
}

fun getOddChecker(i： Int( ： Observable = Observable.just(i%2== 0(

在流的末尾，我需要有奇数列表。 所以我做了那个代码：

fun main() {
val numberSource = NumberSource()
numberSource.start()
println("== started ==")
numberSource.getNumberListSource()
.flatMap {
Observable.fromIterable(it)
.flatMap (
{getOddChecker(it)},
{a, b -> a to b}
)
.filter { it.second }
.map { it.first }
.toList()
.toObservable()
}
.subscribe({ println("onNext: $it")},{},{ print("action:onComplete")})
}

上面的代码输出：

== started == 
doOnNext :) 
onNext: [2, 4, 6, 8, 10, 12] 
doOnNext :) 
onNext: [2, 4, 6, 8, 10, 12] 
action:onComplete

上面的代码做了我想要的，但我不得不使用Pair类。零件

.filter { it.second }
.map { it.first }

似乎不太可读。 那么有没有操作员女巫可以简化该代码？

Answer 1

你可以把它简化为这样的内容

getNumberListSource()
.flatMap { Observable.fromIterable(it)
.flatMap { item -> getOddChecker(item).filter {it}.map { item } }
.toList().toObservable()
}
.subscribe({ println("onNext: $it")},{},{ print("action:onComplete")})