机票直达

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都无所谓啦，当然这也仅是我个人见解，可不做参考！