Java rx assembler l'objet résultat de trois appels asynchrones

Question

J'essaie d'assembler un objet résultat en appelant trois services http de manière asynchrone. Chaque service renverra un champ différent.

Comment puis-je y parvenir?

J'ai quelque chose comme ceci:

Résultat obj

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

Méthode

 ResultObj result = new ResultObj(); 


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

Et maintenant? Comment puis-je obtenir chaque résultat et le définir dans ResultObj dans le champ approprié (le résultat des classes pour les classes et le résultat des élèves pour les étudiants).

Pour l'instant, chaque calll récupère l'observation d'un nombre aléatoire.

Cordialement, Ido

Answer 1

Vous devriez prendre un look à CombineLatest.

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