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
Channel实际上是一个并发安全的队列,它可以用来连接协程,实现不同协程之间的通信。
参考: