rx-java - 如何在 RXJava 中过滤列表

Question

我正在尝试过滤 single<list<item>>我从一个方法中得到的

return getList(number)
    .filter { it -> it.age }  <--- problem
    .flatMap { addMoreData(it) }
    .map(mapper)

fun getList(number: Int): Single<List<Item>> {
    //do so things   
}

但在这种情况下我不能这样做因为it有一个 List<Item>而不是 Item .我希望它在 RXJava 中(不想运行循环列表并过滤它的方法)

我该怎么做？

Answer 1

如果getList()返回 Single<List<Item>> , 然后我想 flattenAsObservable 是你想要的:

return getList()
    .flattenAsObservable { it -> it } // Turns it into Observable<Item>
    .filter { it -> it.age }
    .flatMap { addMoreData() }
    .map(mapper)

您还可以使用 .flatMapObservable { list -> Observable.fromIterable(list) } , 但有点冗长。