机票直达
Kotlin 协程之 Flow 详解一 冷流的生产和消费
Kotlin 协程之 Flow 详解二 常用操作符
Kotlin 协程之 Flow 详解三 还是常用操作符
概述
Flow是kotlin协程工具之一,为异步处理服务的,是google官方最新推荐构建 android app MVI 架构的核心工具之一,挂起函数可以异步的返回单个值,但是该如何异步返回多个计算好的值呢?这正是 Kotlin 流(Flow)的用武之地。类似于RxJava的响应式框架,绝大部分场景下二者都是可以互相取代的,相比之下Flow的学习成本更低,而且官方还扩展了repeatOnLifecycle 、flowWithLifecycle 等生命周期关联的函数,天生的优势!好了,废话不多说,本文将详细介绍Flow及其用法(冷流)!
Flow有哪些优点
- 相比LiveData,Flow支持线程调度、背压、数据转换等操作符。而且目前google推荐的MVI架构中,LiveData已经略显吃力,LiveData最适合作为数据的变化响应而不适合作为事件的发起者
- 相比RxJava,RxJava眼花缭乱的操作符增加了不少学习成本,相比之下 Flow的学习成本低且功能不少,而且google官方也是大力推荐
简单示例
flow { //流的生产者
emit(1) // 发射流
}.collect { //流的消费者
value -> println(value)
}
何为冷流
冷流在不调用终端操作符(collect 消费者)的情况下,Flow构建块(flow 生产者)的代码是不会执行的,每一个消费者调用一次Flow,则构建块的代码会从头到尾执行一次。而热流可以不依赖消费者而存活,可以在流之外生成数据,然后传递给流。
冷流的生产和消费
1. Flow的创建(生产流)
- 流构造器 flow {......}
fun flowSimple(): Flow<Int> = flow { //流构造器
emit(1) //发射流
}
- flowOf()
fun flowSimple(): Flow<Int> = flowOf(1,2,3)
- asFlow()
fun flowSimple(): Flow<Int> = listOf(1, 2, 3).asFlow()
- emptyFlow
空流
2. Flow的消费(消费流)
- collect 终端操作符(消费流)
flowSimple().collect {
value -> println(value)
}
总结
以上内容、示例,是不是似曾相识,事件的生产和消费和RxJava用法如出一辙(emit、collect 对应 onNext、subscribe),基本上一致的,不过 这只是刚刚开始,后续操作符、线程调度、生命周期绑定、热流等等的介绍会发现和RxJava还是有所不同的,Flow更简单更直接!
这里补充说两句关于MVI的内容,学习和使用Flow,多多少少都会涉及到MVI的讨论,以及MVVM、MVI的对比&选择等,MVVM核心思想是 view-viewmodel-view 双向数据流,MVI的核心思想是view-intent-viewmodel-state-view 单向数据流,app架构的选择视app和团队大小而定,app、团队越大型越要慎重考虑,尤其是中大型app,架构选择不合适可能会万劫不复!小型app其实就比较随意啦,个人感觉对于小型app而言 MVP、MMVM、MVI都无所谓啦,当然这也仅是我个人见解,可不做参考!