- 协程是一种编程**,不局限于语言。
- 用同步的方式写异步代码。使得代码更优雅。
https://mp.weixin.qq.com/s/Tv-jEjJAn_gZ_M3qBG4Azw
学习一个新东西,最好的就是找一个项目练练手了。早一阵子学习了郭神coolweatherjetpack这个项目,发现郭神的这个项目显得不是那么的MVVM,在View层做了很多逻辑操作。这样还是会显得View层的比较臃肿。于是站在巨人的肩膀上,酷欧天气,协程MVVM版本就这样诞生了,整体**基于郭神的coolweatherjetpack的版本,甚至很多代码比如页面布局我都是直接Copy郭神的。再次感谢郭神。
val weather = MutableLiveData<Weather>()
fun fetchWeather(weatherId: String) {
// launch 表示开启一个协程环境,类似于JS中的Async
launch{
val fetchWeather = repository.fetchWeather(weatherId, MainActivity.KEY) // 这里是运行在IO线程中,进行网络请求
weather.value = fetchWeather.weather!![0] // 这里是主线程了,用于视图更新
}
}
- viewModel 中调用了一个用 suspend 标记的方法,其中方法体中执行了request方法。下面让我们看下request方法。
suspend fun fetchWeather(weatherId: String, key: String) = request{ service.getWeather(weatherId, key) }
- BaseRepository是所有Repository的基类,里面有用 suspend 关键字标记的request方法,并且用WithContext指定此方法运行在 IO 环境中。
open class BaseRepository {
suspend fun <T> request(block: suspend () -> T): T {
return withContext(Dispatchers.IO) {
block()
}
}
}
- 连起来看就是表示,在 IO 线程中,通过网络请求到数据,并且返回。
1.在Activity中订阅了ViewModel中的liveData,用于视图更新。
weather.observe(this@WeatherActivity, Observer{
swipeRefresh.isRefreshing = false
showWeatherInfo(it)
})