Retrofit + RxJavaでリクエストをチェイン化

Question

私は2つのAPIを順番にリクエストし、そのデータをSQLiteに保存したいと思います。

まず私はAPI Aへの要求を作成し、SQLテーブルaにデータを格納します。 API Bに依頼し、テーブルbにデータを、テーブルa_bにデータを格納します。 a_bに格納されたデータは、リクエストBからのものです。

RxJavaを使用してこれを行うにはどうすればよいですか。私は、ラムダ関数を使用していなかった場合は、このためにflatMapを使用することについて、どこかこの

apiService.A() 
    // store in DB here? How? maybe use map()? 
    .flatMap(modelA -> { 
     // or maybe store modelA in DB here? 
     return apiService.B().map(modelB -> { 
      storeInDB()l // store B here ? 
      return modelB; 
     }); 
    }); 

のようなものを読んで、これは通常のネストされた呼び出しのように醜いになります。これはもっと良い方法ですか？

Answer 1

私はmap演算子を使用すると、API呼び出しの結果を格納するようなもので行くための最善の方法だとは思わない（あなたのサービスを想定すると、AはObservable<FooA>返し、サービスBはObservable<FooB>を返します）。私がやりたい何

はdoOnNext事業者の内部でそれらのものを分離することです。私はそれがメインスレッド上で実行されますonNextでDBにデータを保存するためのコードを記述する場合

apiService.A() 
     .doOnNext(modelA -> db.store(modelA)) 
     .flatMap(modelA -> apiService.B()) 
     .doOnNext(modelB -> db.store(modelB)); 

Answer 2

はい、この正確な目的のためにフラットマップを使用できます。以下の例を参照してください

api.serviceA() 
     .flatMap(new Func1<FooA, Observable<FooB>>() { 
      @Override 
      public Observable<FooB> call(FooA fooA) { 
       // code to save data from service A to db 

       // call service B 
       return api.serviceB(); 
      } 
     }) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(new Subscriber<FooB>() { 
      @Override 
      public void onCompleted() { 
      } 

      @Override 
      public void onError(Throwable e) { 

      } 

      @Override 
      public void onNext(FooB fooB) { 
       // code to save data from service B to db 

      } 
     });