我正在使用自定义存储库来获取房间数据库中数据的可观察量,例如:
fun getUsers(): Observable<List<User>> = userDao.getAll()
.toObservable()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnError { Logger.error(tag, "error getting users: ${it.message}") }
.doOnNext { Logger.debug(tag, "fetched ${it.size} users") }
在我的UI(Fragment)中,我在onResume
中开始订阅:
override fun onResume() {
super.onResume()
userObserver = repository.getUsers()
.subscribe {
// handle user
}
}
在onPause
我有:
override fun onPause() {
super.onPause()
userObserver.dispose()
}
因为每次调用repository.getUsers()
,我都会创建一个新的Observable对象。这会导致内存泄漏吗?我是否应该尝试重用观察者而不是处理和重新创建它?
我会把它放在ViewModel中。重新创建片段后,它将重用以前的视图模型。这将提高性能,因为它不必重新创建您的观察者,并且回想起数据库,它只会使用之前获得的内容。