从rx.observable切换到rx.single

rjzwgtxy  于 2021-07-09  发布在  Java
关注(0)|答案(0)|浏览(232)

我在代码中使用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() ?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题