StateFlow初步探究

flow是如何工作的

stateflow是建立在flow的基础上的，要理解stateflow,首先需要对flow有一定的了解,其实flow的原理很简单，不过是建立在了协程的基础上，假设没有协程，实际上flow就是用一个回调(FlowCollector)来进行工作的，加上了协程之后，由于协程支持中断和恢复，让flow可以匹配发送端和接受端的速度，毕竟如果不匹配的话就可以直接中断嘛，

用伪代码来表示flow的流程

flow {
    emit(something) // 上游
}.collect {
    print(it) // 下游
}

// flow函数块的签名如下
flow(suspend block: FlowCollector<T>.() -> Unit): Flow<T> = {
    return object:Flow<T> {
        suspend fun collect(FlowCollector<T> collector) {
            collector.block()
        }
  }
}

可以看到我们调用的emit函数实际上就是collect方法体的代码，也就是说流的数据是由订阅驱动的，这也是为什么我们把flow叫做冷流，当然实际代码为了满足流的约束，创建的并非简单的匿名类，而是通过SafeFlow 和SafeCollector 满足流的约束,

1. flow是通过flowOn来进行上游数据发送实际线程进行切换的，在调用emit时我们不应该自己去切换上下文
2. 上游取消了应该能够联动下游
3. 下游取消了也需要能够联动上游

上游取消了能够联动下游，对于在同一个协程的flow来说，这是天然可以做到的事情，上游取消了，下游的代码自然就不执行了，对于不在同一个协程的flow呢?，通过在collect的时候使用coroutineScope 创建一个新的协程和作用域，如果collect所在的方法的协程被取消了，那么下游和上游都能够取消，

SafeCollector所做的一件事就是如果下游触发异常了，那么上游后续发送的数据下游都不会在接收了,原理这里后续再分析

flow是如何切换线程的

通过flowOn指定Dispatcher,然后为上游创建一个Channel和运行在新Dispatcher的协程，订阅上游的数据，并且通过Channel下发往下游,下游运行在collect的协程，通过订阅channel的数据，从而达到线程切换的目的，flowOn可以多次指定

StateFlow

StateFlow是建立在flow基础上，可以通过将最新的状态推送到订阅者，原本的flow是封闭的，不支持对外去更改值，然后触发更新，本质上StateFlow维护了一个观察者模式，当State有更新的时候将这个更新传递给所有观察者，但因为协程的存在，需要对所有观察者维护额外的状态，比如当将一个值传递给下游协程时，下游协程可以被中断，直到新值传入再唤起下游的协程，这里StateFlow是通过内部的Slot再维护多余的状态来做到这件事的，

Slot的状态有 null → NONE → PENDING or 下游Continuation → 传递新值

StateFlow 只有当数据更新时才会通知下流，这避免了LiveData的一些问题

StateFlow和SharedFlow有何不同

SharedFlow支持n个数据的重放，这个n是可配置的，StateFlow永远只保存最新的数据