collect

abstract fun collect(scope: CoroutineScope, collector: (CoroutineScope, T) -> Job): Job

收集此 Flow 发出的所有值。

这是一个终端操作符,它会启动上游所有 Flow 操作的执行。 对于每个发出的值,提供的 collector 函数都会被调用。

Return

一个 Job,代表整个收集过程的生命周期。当 Flow 完成或被取消时,此 Job 也会完成。

Parameters

scope

执行收集操作所在的协程作用域。

collector

一个函数,用于处理 Flow 发出的每个值。它接收两个参数: - scope: 用于执行处理逻辑的协程作用域。 - value: Flow 发出的当前值。 此函数需要返回一个 Job,代表对该值处理过程的生命周期。