RxJava for循环与异步方法？

Question

我正在学习在Android上使用RxJava。在我的项目中，我遇到了一种情况，从服务器获取List个项目，并且我需要获取每个项目的详细信息，然后才将响应返回给UI。

问题是：我不知道如何sync在for loop内调用的API调用。我只想在foor loop中的所有调用完成后才将最终结果返回到UI。

任何提示是高度赞赏。

示例代码：

所有的

Observable<List<Favorite>> result = ApiWrapper.getFavorites(userData) 
      .flatMap(new Func1<List<Favorite>, Observable<List<Favorite>>>() { 
       @Override 
       public Observable<List<Favorite>> call(@NonNull final List<Favorite> response) { 
       for(int i = 0; i < response.size(); i++){ 
        getDetailsForFavoriteItem(response.get(i)); 
       } 
       return Observable.just(response);    
       } 
      }); 

private Observable<Favorite> getDetailsForFavoriteItem (Favorite item){ 
    return ApiWrapper.getDetails(item.getId()) 
     .flatMap(new Func1<FavoriteDetailsResponse, Observable<Favorite>>() { 
       @Override 
       public Observable<Favorite> call(@NonNull final FavoriteDetailsResponse response) { 
       item.setParam1(response.getParam1()); 
       item.setParam2(response.getParam2); 
       //so on 
       return Observable.just(item)//!!!issue is here ! I want this return to be called only after all the details (in the for loop) have been called    
       } 
      }); 
} 

Answer 1

首先，在你的getDetailsForFavoriteItem() API不叫，因为你没有预订至Observable。

其次，最好是flatMap将你的第一个回应放入一个Observable<Favorite>然后再flatMap它再次得到它的细节。事情是这样的：

Observable<List<Favorite>> result = ApiWrapper.getFavorites(userData) 
      .flatMapIterable(favorites -> favorites) 
      .flatMap(favorite -> getDetailsForFavoriteItem(favorite)) 
      .toList(); 

你甚至可以使并行调用通过让您的详细信息：

Observable<List<Favorite>> result = getFavorites() 
      .flatMapIterable(favorites -> favorites) 
      .flatMap(favorite -> getDetailsForFavoriteItem(favorite) 
        .subscribeOn(Schedulers.io()), maxConcurrentCalls) // be sure to limit your maxConcurrentCalls or you might get OOM error 
      .toList();