【发布时间】:2019-02-20 09:19:39
【问题描述】:
我正在使用自定义存储库来获取房间数据库中数据的 observables,例如:
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(片段)中,我在 onResume 中开始订阅:
override fun onResume() {
super.onResume()
userObserver = repository.getUsers()
.subscribe {
// handle user
}
}
在onPause 我有:
override fun onPause() {
super.onPause()
userObserver.dispose()
}
由于每次调用repository.getUsers(),我都会创建一个新的 Observable 对象。这会导致内存泄漏吗?我是否应该尝试重用观察者而不是处置和重新创建它?
【问题讨论】:
标签: android kotlin android-room rx-android rx-kotlin