Zinciri iki retrofit gözle görülür zincirleme w/RxJava

Question

2 ağ çağrısını birbiri ardına yürütmek istiyorum. Her iki ağ çağrısı da Gözlenebilir. İkinci çağrı, ilk aramanın başarılı sonucundan veri kullanır, ikinci aramanın başarılı sonucundaki yöntemde, numaralı telefonun verileri numaralı telefonun ilk ve ikinci çağrısının başarılı sonucudur. Ayrıca hem onError "olayları" farklı şekilde ele alabilmeliyim. Ben aşağıdaki örnekte olduğu gibi bu kaçınarak geri arama cehennem elde edebilirsiniz Nasıl:

 API().auth(email, password) 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Action1<AuthResponse>() { 
       @Override 
       public void call(final AuthResponse authResponse) { 
        API().getUser(authResponse.getAccessToken()) 
          .subscribe(new Action1<List<User>>() { 
           @Override 
           public void call(List<User> users) { 
            doSomething(authResponse, users); 
           } 
          }, new Action1<Throwable>() { 
           @Override 
           public void call(Throwable throwable) { 
            onErrorGetUser(); 
           } 
          }); 
       } 
      }, new Action1<Throwable>() { 
       @Override 
       public void call(Throwable throwable) { 
        onErrorAuth(); 
       } 
      }); 

Ben zip bilmem ama ben için "Birleştirici sınıfı" oluşturarak kaçınmak istiyorum. 1.

Güncelleme akarnokd cevabını uygulamaya çalıştı:

  API() 
      .auth(email, password) 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .flatMap(authResponse -> API() 
        .getUser(authResponse.getAccessToken()) 
        .doOnError(throwable -> { 
         getView().setError(processFail(throwable)); 
        }), ((authResponse, users) -> { 
       // Ensure returned user is the which was authenticated 
       if (authResponse.getUserId().equals(users.get(0).getId())) { 
        SessionManager.getInstance().initSession(email, password, authResponse.getAccessToken(), users.get(0)); 
        getView().toNews(); 
       } else { 
        getView().setError(R.string.something_went_wrong); 
       } 
      })); 

Ancak flatMap içindeki yöntem derleyici o authResponse ve kullanıcılara (authResponse.getAccessToken(), users.get(0) vs.) yöntemlerini çözemezse söylüyor. Rx programlama ve lambdas için yeni - lütfen sorunun ne olduğunu söyle. Neyse kod şimdi daha temiz görünüyor.

Güncelleme 2.

API() 
      .auth(email, password) 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .doOnError(throwable -> getView().setError(processFail(throwable))) 
      .flatMap((AuthResponse authResponse) -> API() 
        .getUser(authResponse.getAccessToken()) 
        .doOnError(throwable -> getView().setError(processFail(throwable))), ((AuthResponse authResponse, List<User> users) -> { 
          // Ensure returned user is the which was authenticated 
          if (authResponse.getUserId().equals(users.get(0).getId())) { 
           SessionManager.getInstance().initSession(email, password, authResponse.getAccessToken(), users.get(0)); 
           getView().toNews(); 
          } 
          return Observable.just(this); 
      })); 

böyle yaptın mı, ama şimdi benim ağ aramaları hiç yürütme değildir.

Answer 1

, sizin için birincil ve düzleştirilmiş değerleri bir FUNC2 ve çiftleri götüren bir flatMap aşırı yük vardır. Buna ek olarak, onErrorXXX ve hata manipülasyon için onExceptionXXX operatörleri bakmak ve ilk ve ikinci Gözlenebilirler ile zincirleyin

first.onErrorReturn(1) 
.flatMap(v -> service(v).onErrorReturn(2), (a, b) -> a + b); 

Answer 2

FlatMap()? Eğer (veya zip()) 'e olan ilginiz, sadece iki nesneyi tutmak için gereksiz bir sınıf yapma gereğidir, android.util.Pair bir cevap olabilir. Yine de tam olarak aradığınız hata işleme yöntemini nasıl alacağımı bilmiyorum. Anthony R. cevabı ek olarak

 API().auth(email, password) 
     .subscribeOn(Schedulers.newThread()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .flatMap(new Func1<AuthResponse, Observable<List<User>>>() { 
      @Override 
      public Observable<List<User>> call(AuthResponse authResponse) { 
      return API().getUser(authResponse.getAccessToken()); 
      } 
     }, new Func2<AuthResponse, List<User>, Pair<AuthResponse, List<User>>>() { 
      @Override 
      public Pair<AuthResponse, List<User>> call(AuthResponse authResponse, List<User> users) { 
      return new Pair<>(authResponse, users); 
      } 
     }).subscribe(new Action1<Pair<AuthResponse, List<User>>>() { 
      @Override 
      public void call(Pair<AuthResponse, List<User>> pair) { 
      doSomething(pair.first, pair.second); 
      } 
     }, new Action1<Throwable>() { 
      @Override 
      public void call(Throwable throwable) { 
      // not sure how to tell which one threw the error 
      } 
     });