根据条件将RxJava观察者添加到链中

Question

我正在编写一个Android应用程序。在某些时候，我需要检查从Retrofit方法返回的结果，如果它返回true - 再执行一个API请求。如果没有的Rx逻辑是这样的：

if(api.isVip()) { 
    checkIfPendingCancellation(); 
} else { 
    JoinVipActivity.start(); 
} 

checkIfPendingCancellation() { 
    if(api.pendingCancel()) { 
     YourVipIsAboutToCancelActivity.start(); 
    } else { 
     CancelVipActivity.start(); 
    } 
} 

我知道这是可能的，其中Rx包一切，但不完全知道如何做到这一点。有什么建议么？

Answer 1

假设API是基于非RxJava，你可以做这样的事情：

Observable.just(1) 
.map(v -> { 
    if (api.isVip()) { 
     if (api.pendingCancel()) { 
      return 1; 
     } 
     return 2; 
    } 
    return 3; 
}) 
.subscribeOn(Schedulers.io()) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(v -> { 
    if (v == 1) { 
     YourVipIsAboutToCancelActivity.start(); 
    } else 
    if (v == 2) { 
     CancelVipActivity.start(); 
    } else { 
     JoinVipActivity.start(); 
    } 
}); 

（备注：Observable.just(1).map().subscribeOn()是我用以推动一个最初的同步处理个人最喜欢的方式）

否则，由于改造不支持RxJava的观测量（？与桥我认为），你可以有两种API调用Observable<Boolean>在这种情况下，你可以使用flatMap：

api.isVip() 
.flatMap(b -> { 
    if (b) { 
     return api.pendingCancel().map(c -> c ? 1 : 2); 
    } 
    return Observable.just(3); 
}) 
.subscribeOn(Schedulers.io()) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(v -> { 
    if (v == 1) { 
     YourVipIsAboutToCancelActivity.start(); 
    } else 
    if (v == 2) { 
     CancelVipActivity.start(); 
    } else { 
     JoinVipActivity.start(); 
    } 
});