使用Realm查询时,利用asObservable(),必须在MainThread线程监听,否则无法获取到数据,代码如下:
realm.where(GankInfo::class.java)
.findAllAsync()
.asObservable()
.mainUI()
.subscribe(
{
showList(it)
Timber.i(it.toString())
}
,
Throwable::printStackTrace
)
其中.mainUI()为kotlin的Extension方法:
fun <T> Observable<T>.mainUI(): Observable<T> {
return observeOn(AndroidSchedulers.mainThread())
}
发文方便自己查询,能够帮到大家就最好了。
网友评论