Kombinieren Anfragen mit Retrofit2 und RxJava2

Question

Ich versuche, zwei Anfragen mit der gleichen Observer zu beobachten. Mein Observer:

private BaseObserver<LoginResponse> loginObserver = new BaseObserver<LoginResponse>(this) { 
    @Override 
    public void onSubscribe(Disposable d) { 
     super.onSubscribe(d); 
     showLoading(true); 
     Log.d(TAG, "onSubscribe: "); 
    } 

    @Override 
    public void onNext(LoginResponse response) { 
     super.onNext(response); 
     Log.d(TAG, "onNext: "); 
    } 

    @Override 
    public void onComplete() { 
     super.onComplete(); 
     showLoading(false); 
     Log.d(TAG, "onComplete: "); 
    } 

    @Override 
    public void onError(Throwable e) { 
     super.onError(e); 
     showLoading(false); 
    } 
}; 

Mein Wunsch ist eine Login-Anfrage mit Retrofit2 bauen:

private void sendRequest(String username, String password) { 
    IResourceAPI iResourceAPI = RetrofitClient.createIResourceClient(this); 
    iResourceAPI.login(new LoginRequest(username, password)) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribeWith(loginObserver); 
} 

Jetzt möchte ich zwei oder mehr Anfragen starten und die Antworten eins nach dem anderen in onNext überprüfen, und wenn die letzte Anfrage wird überprüft, führen Sie onComplete mit meiner Observer. Könnte mir bitte jemand helfen?

Vielen Dank im Voraus.

Answer 1

Sie suchen nach dem merge Betreiber:

Sie die Ausgabe von mehreren Observable kombinieren kann, so dass sie wie eine einzige beobachtbare handeln, durch den Merge-Operator.

ändern Sie Ihre Anfrage ein beobachtbares zurückzukehren:

private Observable<LoginResponse> request(String username, String password) { 
    IResourceAPI iResourceAPI = RetrofitClient.createIResourceClient(this); 
    iResourceAPI.login(new LoginRequest(username, password)) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
} 

Dann verschmelzen:

Observable.merge<LoginResponse>(request(...), request(...)) 
    .subscribeWith(loginObserver); 

Answer 2

Es klingt wie Sie für merge Betreiber suchen.