private

{println(it)}println(收集结束)}}/***

创建flow

{delay(1000)emit(1)delay(1000)emit(2)delay(1000)emit(3)}通过该flow扩展函数可以了解到如下信息

函数定义泛型时需要将泛型放到fun

kotlinx.coroutines.flow.FlowCollectorT.()

kotlin.Unit)定义好之后函数中传参也可以使用该泛型继续向下传递例如这里传递给了FlowCollector接口用于规定flow收集器应该发送什么数据给调用方

方式2

扩展函数其实内部也是调用flow扩展函数只不过flowof是将传递进来的可变参数遍历了一遍并且调用flow收集器的emit方法发送取出而已

方式3

{println(it)}}}调用list顶级接口类Iterable的asFlow方法其实内部还是调用了flow扩展函数将元素遍历之后emit出去的

取消或中断flow

$i)emit(i)}}通过withTimeoutOrNull

在30秒内处理不完数据状态的转换就直接结束当前处理只展示处理过后的数据就可以了。

因为有些场景下数据量较大用户等待时间太长的情况下一般用户无法接受所以只能采用妥协的方式来规定一个最大等待时间来处理该组数据。

一般会用在对数据做某种优化处理但这种处理即使处理不完的情况下产品也能接受的情况下才会采用该方案。

否则不建议执行兜底方案处理。

Flow

是Flow中最常用最基础的末端操作符主要用于Flow启动流的挂起函数。

除了collect还有一些其他的操作符例如

toList/toSet/toCollection用于流元素计算的操作符reduce

fold计算数量的操作符count用于切换协程作用域线程的操作符launcherIn/productIn/broadcastIn,

collect

是Flow最基础的操作符大多数场景下都会使用它来收集Flow中生产的数据信息

runBlocking

{listOf(1,2,3,4,5).asFlow().collect

value

listOf(1,2,3,4,5).asFlow().reduce

private

b}println(求集合中的最大值${maxNum})}}fold

操作符使用

也是用于计算的操作符只不过fold可以设置累加器的初始值与reduce相比

private

}println(设置初始值后的累加结果$sum)}}launchIn

操作符使用

launchIn用于指定协程作用域如果单独看如下这块代码可能觉得launchIn好像没有什么作用但是一旦多个流想要并发执行时launchIn就可以起到它该有的作用为流指定了协程作用域之后相当于每个流开启了一个协程每个流都在自己协程中运行所以可以使用launchIn来实现并发的功能。

val

Executors.newSingleThreadExecutor().asCoroutineDispatcher()private

fun

CoroutineScope(mDispatcher)(1..5).asFlow().onEach

println(it)