我在代码中使用rx.observable,当我迁移到rxjava的新版本时,我需要切换到rx.single。
下面是如何在代码中使用rx.observable的示例:
obj.doSomething()
.filter(res -> {
return res.getStatus() == 0 ? true : false;
})
.subscribe(res -> {
handleResult(res);
});
对于新的rxjava版本,我不得不改变 doSomething()
返回rx.single,所以我不能使用 .filter()
再让我在 .subscribe()
.
我不太喜欢它,因为它有一个特殊的。过滤器块,用来处理控制,以防 false
它不会到达 .subscribe()
.
任何解决方法或更好的设计,以避免处理中的样板代码 .subscribe()
?
暂无答案!
目前还没有任何答案,快来回答吧!