I have following project in 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()。
What should I do to have a call on refreshShows() every time onCreate()
callback of Activity get called?
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)
}
}
仅当完成新的网络请求时,才会调用ur存储库中的Ur refreshShows()。实时数据的想法是在重新创建其片段/活动时提供最新的结果,因此当屏幕旋转或您恢复活动时,它不会触发另一个请求,因为实时数据已经具有最新的结果并且您没有与之建立状态连接您的网络数据库/服务器(如果您正在从Room观察数据,则它将接收到最新的更改)。
我发现“修复”此问题的最简单方法是使您的viewmodel val显示很有趣,如下所示:
但是使用这种方法,每次屏幕旋转时都会进行新的网络调用,从而调用ur refreshShows()