在RxJava中组合父细节请求

Question

我有一个从服务器获得的a类对象列表。这个类A除了其他项外，还包含一个id列表。然后使用这些id检索类b的对象列表。

我有返回 的函数

Observable<List<A>>

和

Observable<B>

。

我想使用RxJava来检索A对象的列表，然后检索每个A对象的B对象列表，并将B对象分配给它们所属的A对象，所以我想以类似于以下的一些复合对象的列表结束:

class Details {
    public A a;
    public List<B> listOfB;
}

并返回

Observable<List<Details>>

谢谢!

Answer 1

假设，如您所述，您有以下函数:

Observable<List<A>> getAList()

和

Observable<B> getB(Long id)

基本上你需要使用Observable.from方法来解耦列表到单个元素，当然Observable.flatMap来转换Observable。

创建辅助函数从A的列表中获取B的列表:

public Observable<List<B>> getBFromAList(List<Long> idList) {
    return Observable.from(idList)
            .flatMap(new Func1<Long, Observable<B>>() {
                @Override
                public Observable<B> call(Long id) {
                    return getB(id);
                }
            })
            .toList();
}

和主要功能:

public Observable<List<Details>> getDetailsList() {
    return getAList()
            .flatMap(new Func1<List<A>, Observable<A>>() {
                @Override
                public Observable<A> call(List<A> aList) {
                    return Observable.from(aList);
                }
            }).flatMap(new Func1<A, Observable<Details>>() {
                @Override
                public Observable<Details> call(A a) {
                    return getBFromAList(a.idList)
                            .zipWith(Observable.just(a), new Func2<List<B>, A, Details>() {
                                @Override
                                public Details call(List<B> bs, A a) {
                                    Details details = new Details();
                                    details.a = a;
                                    details.listOfB = bs;
                                    return details;
                                }
                            });
                }
            }).toList();
}