Rxjava、改造および複数のコール

最近、Rxjavaを使用して改造し、n個の改造後の呼び出しを実行し、rxjava経由でそれらを追跡する方法に関するアイディアを探し始めました。すべてのアクションが完了すると、UIイベントが発生します。Rxjava、改造および複数のコール

私はこの記事を見つけました：http://randomdotnext.com/retrofit-rxjava/しかし、それはforループを使用して複数のリクエストオブザーバを開始します。多分、forループの他にもっとエレガントな方法がありますか？この種の作業に最適なrxjava演算子は何ですか？

出典

2016-07-21 zosocanuck

forループを使用する代わりに、List/ArrayからObservableシーケンスを作成してから、flatMap/concatMap演算子を使用できます。 forループを使用して

：

GithubService service = ServiceFactory.createRetrofitService(GithubService.class, GithubService.SERVICE_ENDPOINT); 
for(String login : Data.githubList) { 
    service.getUser(login) 
     .subscribeOn(Schedulers.newThread()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(new Subscriber<Github>() { 
      @Override 
      public final void onCompleted() { 
       // do nothing 
      } 

      @Override 
      public final void onError(Throwable e) { 
       Log.e("GithubDemo", e.getMessage()); 
      } 

      @Override 
      public final void onNext(Github response) { 
       mCardAdapter.addData(response); 
      } 
     }); 

}

ピュアのRx：

GithubService service = ServiceFactory.createRetrofitService(GithubService.class, GithubService.SERVICE_ENDPOINT); 
Observable.from(Data.githubList) 
.flatMap(login -> service.getUser(login)) 
.subscribeOn(Schedulers.newThread()) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(...);

出典

2016-07-21 06:07:11