Rx Java Android Doit appeler plusieurs API dans une séquence et sauvegarder chaque résultat.

Question

Je veux appeler plusieurs Api de repos dans une séquence et chaque Dto de réponse est différent l'un de l'autre.

S'il vous plaît aidez-moi à se débarrasser de cette situation que, Comment puis-je appeler ces Api utilisant Rx Java Observables dans Android.

Answer 1

Pour le même scénario, j'utiliser l'opérateur de concat qui prend plusieurs Observables et concaténer leur séquence

Si la séquence de réponse ne nécessite pas alors vous pouvez utiliser l'opérateur de fusion aussi.

Concat VS Merge operaror

Answer 2

essayer doOnNext() ou map() méthode de Observable et utiliser la synchronisation execute() de chaque réponse et les transmettre plus

Answer 3

non, vous devez utiliser map() ou doOnNext(), il ressemblera à ceci

Observable.just(1) 
    .doOnNext(value -> { 
     someRequestX().execute();  
    }) 
    .map(value -> { 
     return nextRequestY().execute();  
    }) 
    .doOnNext(requestYResponse-> { 
     someRequesZ(requestYResponse.someValue).execute();  
    }) 
    .map(requestYResponse-> { 
     return someRequesK(requestYResponse.someValue).execute();  
    }) 
    .map(requestKResponse -> { 
     return someRequesJ(requestKResponse.someValue).execute();  
    }) 
    .subscribe(requestJResponse -> { 
     doSOmethingWithFinalResponse(requestJResponse); 
    }) 

Answer 4

Tout d'abord, pour les demandes de réseau est préférable d'utiliser Single puis Observable, bec ause il y aura toujours un seul article. Pour passer d'une requête à l'autre, vous pouvez utiliser flatMap.

Si l'on suppose que votre code est similaire, vous pouvez essayer:

class Dto1 {} 

class Dto2 {} 

class Dto3 {} 

public interface Api { 

    Single<Dto1> getDto1(); 

    Single<Dto2> getDto2(); 

    Single<Dto3> getDto3(); 
} 

private Api api; 

public void callApi() { 
    api.getDto1() 
      .doOnSuccess(dto1 -> {/*do something with dto1*/}) 
      .flatMap(dto1 -> api.getDto2()) 
      .doOnSuccess(dto2 -> {/*do something with dto2*/}) 
      .flatMap(dto2 -> api.getDto3()) 
      .doOnSuccess(dto3 -> {/*do something with dto3*/}) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe() 
}