尝试使用Rx
Java适配器测试新的
Android Room librarty.如果我的查询从DB返回0个对象,我想处理结果：
所以这是DAO方法：
@Query("SELECT * FROM auth_info")
fun getAuthInfo(): Flowable<AuthResponse>
以及我如何处理它：
database.authDao().getAuthInfo()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.switchIfEmpty { Log.d(TAG,"IS EMPTY") }
.firstOrError()
.subscribe(
{ authResponse -> Log.d(TAG,authResponse.token) },{ error -> Log.d(TAG,error.message) })
我的数据库是空的,所以我希望.switchIfEmty()可以工作,但是处理方法都没有被触发.既没有.subscribe()也没有.switchIfEmpty()
