3つの非同期呼び出しのJava rxアセンブル結果オブジェクト

Question

3つのHTTPサービスを非同期的に呼び出すことによって結果オブジェクトをアセンブルしようとしています。各サービスは異なるフィールドを返します。

どのように達成できますか？

私はこのようなものがあります：

結果OBJ

public class ResultObj { 
    int resStudents; 
    int resClasses; 
    int resGrades; 
} 

方法

 ResultObj result = new ResultObj(); 


Observable.merge(studentService.fetchTotal(), classesService.fetchTotal(), gradesService.fetchTotal()) 
       .toBlocking(); 

今何を？ どのように各結果を取得し、適切なフィールドにResultObjに設定するのですか？（クラスの結果は生徒のための結果となります）。

今のところ、各フェッチコールは、乱数のObservalbleを再実行します。

よろしく、イド

Answer 1

あなたはCombineLatestでlookを取る必要があります。

Observable.combineLatest(
    studentService.fetchTotal(), 
    classesService.fetchTotal(), 
    gradesService.fetchTotal(), 
    (studentTotal, classesTotal, gradesTotal) -> { 
     // do your stuff 
     return studentTotal + classesTotal + gradesTotal; 
    }) 
    .subscribe(
     total -> System.out.println(total) 
    ) 
);