*/
private suspend fun executeResponse(
response: BaseResult,
success: suspend CoroutineScope.(T) -> Unit
) {
coroutineScope {
if (response.errorCode == 0 ) success(response.data)
else throw ResponseThrowable(response.errorCode, response.errorMsg)
}
}

最后我们再写一个 launchOnlyresult 方法把他们结合起来:

fun launchOnlyresult(
block: suspend CoroutineScope.() -> BaseResult,
success: (T) -> Unit,
error: (ResponseThrowable) -> Unit = { },
complete: () -> Unit = {}
) {
launchUI {
handleException(
{ withContext(Dispatchers.IO) { block() } },
{ res ->
executeResponse(res) { success(it) }
},
{
error(it)
},
{
complete()
}
)
}
}

异常类的代码就不贴了,没什么好说的,末尾会给Demo地址,在里面看吧,现在我们获取Banner数据就变成这样了:

fun getBanner() {
launchOnlyresult({ repository.getBanner() }, {
LogUtils.d(it) // it是Banner 数据
})
// 处理Error
/launchOnlyresult({ repository.getBanner() }, {
mBanners.value = it
},{
LogUtils.d(it.errMsg)
})
/
}

我们的一个请求已经可以简单成这个样子了,相比于用RxJava的方式是不是更舒服呢。说到这里有的兄弟可能就说了,单个网络请求确实很简单,但是如果多个呢?还有些请求要依赖其他请求的结果呢?我们在业务逻辑越来越复杂,RxJava有多种操作符来使用,你这个要怎么搞?
接下来另一个人物要登场了,带着这些问题我们再来说下协程的另一个东西 Flow 异步流

3.2 Flow

带着上面的问题我们看下Flow 能干什么,看着名字可能有些陌生,但是我们了解之后肯定又会非常熟悉。他翻译成中文是 意思,我们在协程中,做异步可以返回一个值,当我们想返回多个值的时候,Flow就开始展现他的作用了,我们看下具体使用场景: 我们看玩安卓的 导航数据项目列表数据 两个接口,获取项目列表的时候需要依赖导航数据接口里边的 id,我们来用Flow实现 首先是Servie:

/**

  • 导航数据
    */
    @GET(“project/tree/json”)
    suspend fun naviJson(): BaseResult<List>

/**

  • 项目列表
  • @param page 页码,从0开始
    */
    @GET(“project/list/{page}/json”)
    suspend fun getProjectList(@Path(“page”) page: Int, @Query(“cid”) cid: Int): BaseResult

ViewModel中的实现:

@ExperimentalCoroutinesApi
@FlowPreview
fun getFirstData() {
launchUI {
flow { emit(repository.getNaviJson()) }
.flatMapConcat {
return@flatMapConcat if (it.isSuccess()) {
// 业务操作 …
// LogUtils.d(it) // it 是BaseResult<List>
// …
flow { emit(repository.getProjectList(page, it.data[0].id)) }
} else throw ResponseThrowable(it.errorCode, it.errorMsg)
}.onStart{
// 会在 emit 发射之前调用
}
.flowOn(Dispatchers.IO) // 这个是指烦气发射的所在协程
.onCompletion {
// 流执行完毕会调用
}
.catch {
// 遇到错误时会调用
}
.collect {
// 收集 ,FLow只有在我们
LogUtils.d(it) // it 是BaseResult
}

}
}

有的兄弟可能看到上边代码会说,似曾相识啊,没错跟RxJava是一个思想,Flow只能运行在协程中,上边的代码优化过后:是这个样子的:

@ExperimentalCoroutinesApi
@FlowPreview
fun getFirstData() {
launchUI {
launchFlow { repository.getNaviJson() }
.flatMapConcat {
return@flatMapConcat if (it.isSuccess()) {
navData.addAll(it.data)
it.data.forEach { item -> navTitle.add(item.name) }
launchFlow { repository.getProjectList(page, it.data[0].id) }
} else throw ResponseThrowable(it.errorCode, it.errorMsg)
}
.onStart { defUI.showDialog.postValue(null) }
.flowOn(Dispatchers.IO)
.onCompletion { defUI.dismissDialog.call() }
.catch {
// 错误处理
val err = ExceptionHandle.handleException(it)
LogUtils.d(“${err.code}: ${err.errMsg}”)
}
.collect {
if (it.isSuccess()) items.addAll(it.data.datas)
}
}

}

Demo中使用了LiveData 更新数据,如果把所有东西都贴出来实在有点多,只放了部分代码。来简单说下这些操作符的作用吧:

  • flow:构建器,他可以发射数据多个数据,用**emit()**来发射
  • flatMapConcat :这个是在一个流收集完成之后,再收集下一个流
  • onStart:这个看名字估计也能猜出来,就是在发射之前做一些事情,我们可以在这里再 emit()一个数据,他会在flow里边的数据发射之前发射,我们上边的例子,是在OnStart里边打开了等待框
  • flowOn:这个就是指定我们的流运行在那个协程里边,我们指定的是 Dispatchers.IO
  • onCompletion :是在所有流都收集完成了,就会触发,我们可以在这里取消等待框再合适不过了
  • catch:这个就是遇到错误的时候会触发,我们我错误处理就是在这里来做了
  • collect:这个就是收集器的意思,我们的结果都在这里来处理。也只有我们调用了这个收集方法,数据才真正的开始发射了,这也是官方说的一句话,流是冷的,就是这个意思

卧槽,无情,这TM明明就跟RxJava是孪生兄弟啊,你说的没错,FLow,他还有好多操作符供我们使用。
比如 :
zip 合并流
flatMapMerge 让流并发进行
transform 转换操作符
在这里就不一 一列举了。 他还提供了 转换成 响应式流 Reactive Streams(RxJava)的方法。
相信熟悉RxJava的你,分分钟钟就可以上手的

3.2其他小例子
3.2.1 验证码倒计时

有了上面的介绍,我们对协程肯定有了或多或少的了解,我在公司项的新项目中也已经开始使用了,再分享个小例子,新项目中一第一个做的就是登录功能,既然是登录就少不了验证码倒计时,我们用 协程+LiveData 来实现他:

@ExperimentalCoroutinesApi
fun getSmsCode(phone: String) {
viewModelScope.launch {
flow {
(60 downTo 0).forEach {
delay(1000)
emit(“$it s”)

自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数Android工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Android移动开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。
img
img
img
img
img
img
img

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Android开发知识点,真正体系化!

由于文件比较大,这里只是将部分目录大纲截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且后续会持续更新

如果你觉得这些内容对你有帮助,可以添加V获取:vip204888 (备注Android)
img

最后

针对于上面的问题,我总结出了互联网公司Android程序员面试涉及到的绝大部分面试题及答案,并整理做成了文档,以及系统的进阶学习视频资料。
(包括Java在Android开发中应用、APP框架知识体系、高级UI、全方位性能调优,NDK开发,音视频技术,人工智能技术,跨平台技术等技术资料),希望能帮助到你面试前的复习,且找到一个好的工作,也节省大家在网上搜索资料的时间来学习。

image

一个人可以走的很快,但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎扫码加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
img
料的时间来学习。**

[外链图片转存中…(img-OPxil2x8-1712652155449)]

一个人可以走的很快,但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎扫码加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
[外链图片转存中…(img-vyYDFiVL-1712652155449)]

Logo

开源鸿蒙跨平台开发社区汇聚开发者与厂商,共建“一次开发,多端部署”的开源生态,致力于降低跨端开发门槛,推动万物智联创新。

更多推荐