我有一个返回Observable<ArrayList<Long>>
的方法,它是一些项的ids。我想浏览一下这个列表,并使用另一个返回Observable<Item>
的方法下载每个项目。
如何使用RxJava运算符执行此操作?
发布于 2018-06-13 20:08:51
在Kotlin中使用flattenAsFlowable
repository.getFlowableData(id)
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.computation())
.toList()
.flattenAsFlowable { it }
.map { someMethod(it) }
.observeOn(AndroidSchedulers.mainThread())
.subscribe({ },
{ onError(it) })
发布于 2020-10-25 17:19:02
对于Kotlin
Observable
.fromIterable(listOfChallenges) // list of challenges which contain challenge ID
.flatMap { eachChallenge ->
getChallengeDetail(eachChallenge.challengeUid!!) // fetch details of each challenge
}
.toList() // map to list
.subscribe({ listOfEachChallengesDetail ->
}, {
// error
})
https://stackoverflow.com/questions/28035090
复制相似问题