Plusieurs demandes de rénovation pour combiner les résultats

Nous utilisons RxJava dans android et de les combiner de résultat. Je l'ai expliqué chaque étape

Nous allons tout d'abord définir notre objet de Rénovation pour accéder à l'API Github, puis l'installation de deux observables pour les deux demandes de réseau ci-dessus:

Retrofit repo = new Retrofit.Builder()
        .baseUrl("https://api.github.com")
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
        .build();

Observable<JsonObject> userObservable = repo
        .create(GitHubUser.class)
        .getUser(loginName)
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread());

Observable<JsonArray> eventsObservable = repo
        .create(GitHubEvents.class)
        .listEvents(loginName)
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread());

La Rénovation des interfaces sont assez simples:

public interface GitHubUser {
  @GET("users/{user}")
  Observable<JsonObject> getUser(@Path("user") String user);
}

public interface GitHubEvents {
  @GET("users/{user}/events")
  Observable<JsonArray> listEvents(@Path("user") String user);
}

Dernièrement, nous utilisons RxJava postal de la méthode de combiner nos deux Observables et attendre pour eux de complet avant de créer un nouveau Observable.

Observable<UserAndEvents> combined = Observable.zip(userObservable, eventsObservable, new Func2<JsonObject, JsonArray, UserAndEvents>() {
  @Override
  public UserAndEvents call(JsonObject jsonObject, JsonArray jsonElements) {
    return new UserAndEvents(jsonObject, jsonElements);
  }
});

Quelle est la UserAndEvents? C'est juste un simple POJO de combiner les deux objets:

public class UserAndEvents {
  public UserAndEvents(JsonObject user, JsonArray events) {
    this.events = events;
    this.user = user;
  }

  public JsonArray events;
  public JsonObject user;
}

Enfin, nous allons appeler la méthode subscribe sur notre nouveau combiné Observables:

combined.subscribe(new Subscriber<UserAndEvents>() {
          ...
          @Override
          public void onNext(UserAndEvents o) {
            //You can access the results of the 
            //two observabes via the POJO now
          }
        });

OriginalL'auteur Ramkailash