我在Github中有以下项目:https://github.com/Ali-Rezaei/TVMaze
我已经开始在示例应用程序中将Koin用作依赖项注入框架:
class TVMazeApplication : Application() {
override fun onCreate() {
super.onCreate()
startKoin {
androidContext(this@TVMazeApplication)
modules(networkModule)
modules(persistenceModule)
modules(repositoryModule)
modules(viewModelModule)
}
}
}
这是我的存储库类:
class ShowRepository(
private val dao: ShowDao,
private val api: TVMazeService,
private val context: Context
) {
/**
* A list of shows that can be shown on the screen.
*/
val shows = resultLiveData(
databaseQuery = {
Transformations.map(dao.getShows()) {
it.asDomainModel()
}
},
networkCall = { refreshShows() })
/**
* Refresh the shows stored in the offline cache.
*/
private suspend fun refreshShows(): Result<List<Show>> =
try {
if (isNetworkAvailable(context)) {
val shows = api.fetchShowList().await()
dao.insertAll(*shows.asDatabaseModel())
Result.success(shows)
} else {
Result.error(context.getString(R.string.failed_internet_msg))
}
} catch (err: HttpException) {
Result.error(context.getString(R.string.failed_loading_msg))
}
}
和我的ViewModel:
class MainViewModel(
repository: ShowRepository
) : ViewModel() {
private val _shows = repository.shows
val shows: LiveData<Result<List<Show>>>
get() = _shows
}
而且我在Activity中观察LiveData:
viewModel.shows.observe(this, Observer { result ->
when (result.status) {
Result.Status.SUCCESS -> {
binding.loadingSpinner.hide()
viewModelAdapter.submitList(result.data)
}
Result.Status.LOADING -> binding.loadingSpinner.show()
Result.Status.ERROR -> {
binding.loadingSpinner.hide()
Snackbar.make(binding.root, result.message!!, Snackbar.LENGTH_LONG).show()
}
}
})
[当我单击“后退”按钮时,活动被销毁(但是应用实例仍然存在,因为我可以从最近的应用中访问它)。我期望的是在再次启动应用程序时调用refreshShows()方法,但是它从未被调用。
但是当我通过清除最近的应用程序并启动该应用程序来破坏该应用程序实例时,会调用refreshShows()。
每次调用Activity的onCreate()
回调时,我应该如何对refreshShows()进行调用?
fun <T, A> resultLiveData(databaseQuery: () -> LiveData<T>,
networkCall: suspend () -> Result<A>): LiveData<Result<T>> =
liveData(Dispatchers.IO) {
emit(Result.loading<T>())
val source = databaseQuery.invoke().map { Result.success(it) }
emitSource(source)
val result = networkCall.invoke()
if (result.status == Result.Status.ERROR) {
emit(Result.error<T>(result.message!!))
emitSource(source)
}
}
您的存储库中的refreshShows()仅在完成新的网络请求时被调用。 livedata的想法是在重新创建其片段/活动时提供最新的结果,因此,当屏幕旋转或您恢复活动时,它不会触发另一个请求,因为livedata已经具有最新的结果并且您没有与之建立状态连接您的网络数据库/服务器(如果您正在查看来自Room的数据,它将收到最新的更改(如果有))。