RxJava单人和房间错误处理问题

Question

我有这个问题关于空数据库返回与房间和RxJava单一。我知道我的数据库是空的，所以我希望在触发时得到一个空的返回

@Query("SELECT * FROM Times WHERE timestamp = :timestamp")
fun getTimes(timestamp: String): Single<Times>

问题是当我调用这个函数如下所示时

timeDao.getTimes("1398332113")
       .observeOn(AndroidSchedulers.mainThread())
       .subscribeOn(Schedulers.io())
       .doOnError { Log.e("Single", "Returned null") }
       .doOnSuccess { result -> times = result}
       .subscribe()

但仍然返回异常和崩溃

w/system.err：io.reactivex.exceptions.onerrornotimplementedexception：查询返回空结果集：SELECT*FROM Times WHERE timestamp=？

我在StackOverflow上看过很多类似的问题，但都找不到答案。我做错了什么？

Answer 1

首先，解决你的问题。由于2.1.0-alpha01Room版本支持maybe返回类型，这对于建模您的问题非常合适。

从文档中可以看到：

可能使用以下顺序协议操作:onsubscribe(onsuccessonerroroncomplete)？

将Dao类中的single替换为maybe将起作用。

进一步说明：

timeDao.getTimes("1398332113")
       .observeOn(AndroidSchedulers.mainThread())
       .subscribeOn(Schedulers.io())
       .doOnError { Log.e("Single", "Returned null") }
       .doOnSuccess { result -> times = result}
       .subscribe()

doonerror将在en错误的情况下执行lambda，但它仍然会沿链发出错误。您的程序崩溃，因为它不处理错误(subscribe()为空）。

默认值不能为null，反应流规范(RxJava2实现了它）不支持null值。