RxJava/RxAndroid改进，使6个不同的可观察调用异步

Question

我正在学习RxJava/Android（我目前正在将其与网络呼叫改造相结合），现在我有一个问题，假设我有6个不同的可观察对象，如下所示：<代码>可观察

apiInterface等为改造客户端，GetClient等为调用

现在，我如何异步执行这6个不同的调用，以及当所有6个调用都完成时-

Answer 1

您应该像这样使用zip操作符：

Observable<Client> clients = apiInterface.getClients()
 Observable<Orders> orders = apiInterface.getOrders();
 Observable<Products> products = apiInterface.getProducts();

Observable<String> clientorders = Observable.zip(
                        clients,
                        orders,
                        products,
                        new Func3<Client, Orders, Products> {
                                @Override
                                public String call(Client client, Orders orders, products products) {


                                      return "progress bar dismissed" ;
                                }
                        }
);     

clientorders.subscribe(new Action1<String>() {

                    @Override
                    public void call(String s) {
                        //action
                        //dimiss progress bar
                    }

                })
}

Zip运算符：http://reactivex.io/documentation/operators/zip.html