Kotlin数据流

Flow是什么

数据流以协程为基础，可以返回多个值，数据流是可通过异步方式进行计算处理的一组数据序列，数据流所发出值的类型必须相同。
数据流包含：提供方，中介（可选），适用方。

冷流

使用Flow创建的就是冷流，冷流不能独立于收集器collect{}存在,且每个数据流需要收集器才能称为一个完整的数据流。当有消费者 collect 或其它终端操作时，流开始从下往上触发，然后从上往下流动。

热流

通过StateFlow或SharedFlow创建的数据流称为热流，它能独立于收集器collect{}存在，可以没有或有多个收集器。

Flow用来做什么

协程和冷流可以替换RxJava进行响应式编程。
热流 SharedFlow 可以用来做事件总线，替换 EventBus。
热流 StateFlow 可以用来做事件状态更新，替换 LiveData，并结合 MVI 替换 MVVM。

Flow怎么用

我们可以通过asFlow(), flowOf(), flow{}创建冷流

fun main() {
    val flow1 = arrayOf(1, 2, 3).asFlow()
    val flow2 = flowOf(4, 5, 6)
    val flow3 = flow<Int> {
        println("emit 7")
        emit(7)
        println("emit 8")
        emit(8)
    }

    runBlocking {
        flow1.map { it + 1 }.collect{
            println("flow1, $it")
        }

        flow2.collect{
            println("flow2, $it")
        }

        flow3.collect{
            println("flow3, $it")
        }
    }
}

SharedFlow和StateFlow

private val _tickFlow = MutableSharedFlow<Unit>(
        replay = 0,
        extraBufferCapacity = 0,
        onBufferOverflow = BufferOverflow.SUSPEND)
val tickFlow: SharedFlow<Event<String>> = _tickFlow

开发中使用MutableSharedFlow#emit或tryEmit发射数据，MutableSharedFlow是SharedFlow的子类。
StateFlow是SharedFlow的子类，StateFlow是一个状态容器可观察数据流，可向收集器发出当前状态更新和新状态更新。当前状态值也可以通过其 value属性读取。如需更新状态并将其发送到数据流，请为 MutableStateFlow类的 value 属性分配一个新值。

private val _uiState = MutableStateFlow(LatestNewsUiState.Success(emptyList()))
    // The UI collects from this StateFlow to get its state updates
val uiState: StateFlow<LatestNewsUiState> = _uiState

StateFlow感觉和LiveData很相似，但他们也有不同之处：LiveData是生命周期感知的，但StateFlow不是，使用StateFlow时需要从 Lifecycle.repeatOnLifecycle 块收集数据流

Channel

image.png

Channel实际上是一个并发安全的队列，它可以用来连接协程，实现不同协程之间的通信。

参考：

1. Android 上的 Kotlin 数据流
2. Kotlin协程之Flow使用
3. Asynchronous Flow
4. Kotlin Flow 冷流和热流
5. Android—kotlin-Channel超详细讲解
6. 学习采用 Kotlin Flow 和 LiveData 的高级协程