Verkettungsanfragen in Retrofit + RxJava

Question

Ich habe 2 APIs, die ich nacheinander anfordern und ihre Daten in SQLite speichern möchte.

Zuerst möchte ich eine Anfrage an die API A stellen und ihre Daten in der SQL-Tabelle a speichern. Dann stellen Sie eine Anfrage an die API B und speichern Sie ihre Daten in der Tabelle b und einige Daten in der Tabelle a_b. Die in a_b gespeicherten Daten stammen von der Anfrage B allein.

Wie kann ich dies mit RxJava tun. Ich habe irgendwo gelesen, über die Verwendung von flatMap dafür, so etwas wie diese

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

Wenn ich nicht Lambda-Funktionen verwenden, dies als normale verschachtelte Anrufe als hässlich aussehen würde. Ist das ein besserer Weg?

Answer 1

Ich glaube nicht, mit map Betreiber ist der beste Weg, Dinge zu gehen, wie das Ergebnis der api Aufruf zu speichern.

Was ich tun möchte, ist diese Dinge innerhalb doOnNext Betreiber zu trennen. So würde Ihr Beispiel so etwas wie dieses:

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

(fügen notwendig observeOn und subscribeOn sich, genau wie Sie sie benötigen)

Answer 2

Ja, Sie können Flatmap für genau diesen Zweck verwenden. Siehe unten stehende Beispiel (Angenommen, Ihre Dienstleistung A kehrt Observable<FooA> und Service-B liefert 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 

      } 
     });