Yêu cầu chuỗi trong Retrofit + RxJava

Question

Tôi có 2 API mà tôi muốn yêu cầu theo thứ tự và lưu trữ dữ liệu của chúng trong SQLite.

Trước tiên, tôi muốn yêu cầu API A và lưu trữ dữ liệu trong bảng SQL a. Sau đó, yêu cầu API B và lưu trữ dữ liệu trong bảng b và một số dữ liệu trong bảng a_b. Các dữ liệu được lưu trữ trong a_b là từ yêu cầu B một mình.

Làm cách nào tôi có thể thực hiện việc này bằng RxJava. Tôi đọc ở đâu đó về việc sử dụng flatMap cho điều này, một cái gì đó như thế này

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

Nếu tôi không sử dụng hàm lambda, điều này sẽ trông xấu xí như cuộc gọi lồng nhau bình thường. Đây có phải là cách tốt hơn để làm điều đó không?

Answer 1

Tôi không nghĩ rằng sử dụng map điều hành là cách tốt nhất để đi với những thứ như lưu trữ các kết quả của các cuộc gọi api.

Điều tôi muốn làm là phân tách những thứ đó bên trong các toán tử doOnNext. Vì vậy, ví dụ của bạn sẽ là một cái gì đó như thế này:

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

(thêm cần thiết observeOn và subscribeOn mình, hệt như bạn cần họ)

Answer 2

Có, bạn có thể sử dụng bản đồ phẳng cho mục đích chính xác này. Xem ví dụ dưới đây (Giả sử dịch vụ của bạn Một trả Observable<FooA> và dịch vụ B trả 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 

      } 
     });