将 Observable<List<SomeObject>> 转换为 List<SomeObject>

Question

如何转换：

Observable<List<SomeObject>> to List<SomeObject>

使用这个：

Observable.just(index)
            .map { d ->
                // returns an Observable<List<someObject>>
            }
            .observeOn(Schedulers.computation())
            .map { r ->
                doSomething(r) // r must be converted to a List<someObject>
            }
            .observeOn(AndroidSchedulers.mainThread())
            .take(1)
            .subscribe {
            }

Answer 1

如果您在第一个 map 中显式返回 Observable<List<SomeObject>>，您应该改为使用 flatMap 将可观察值展平为一个。否则，您的第一个 map 实际上会返回一个 Observable<Observable<List<SomeObject>>>.

将 Observable<List<SomeObject>> 转换为 List<SomeObject>

Convert Observable<List<SomeObject>> to List<SomeObject>

rx-java