Richieste di concatenamento in Retrofit + RxJava

Question

Ho 2 API a cui desidero fare richiesta in sequenza e memorizzare i loro dati in SQLite.

Prima di tutto desidero fare richiesta all'API A e memorizzarne i dati nella tabella SQL a. Quindi fai richiesta all'API B e memorizza i suoi dati nella tabella b e alcuni dati nella tabella a_b. I dati memorizzati in a_b provengono dalla richiesta B.

Come posso farlo utilizzando RxJava. Ho letto da qualche sull'utilizzo flatMap per questo, qualcosa di simile

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; 
     }); 
    }); 

Se non stavo usando funzioni lambda, questo apparirebbe brutto come chiamate annidate normali. È un modo migliore per farlo?

Answer 1

Non credo usando map operatore è il modo migliore per andare con le cose come memorizzare il risultato della chiamata API.

Quello che mi piace fare è separare queste cose dagli operatori doOnNext. Così il vostro esempio potrebbe essere qualcosa di simile:

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

(aggiungere necessaria observeOn e subscribeOn da soli, esattamente come ne avete bisogno)

Answer 2

Sì, è possibile utilizzare flatmap per questo scopo esatto. Vedere l'esempio di seguito (Assumendo che il servizio A torna Observable<FooA> e servizio B torna Observable<FooB>)

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 

      } 
     });