根据条件将 RxJava Observer 添加到链中

Question

我正在编写 Android 应用程序。在某些时候，我需要检查从 Retrofit 方法返回的结果，如果它 returns 为真 - 再执行一个 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() 是我个人最喜欢的快速启动原始同步处理的方式。）

否则，由于 Retrofit 确实支持 RxJava 的 Observables（我想有一个桥？），你可以将两个 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();
    }
});

根据条件将 RxJava Observer 添加到链中

Add RxJava Observer into chain depending on a condition

java

android

rx-java