sdk/com.m8test.script.core.api.coroutines.flow/FlowCollector

FlowCollector

interface FlowCollector<T> : ObjectWrapper<ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>>

FlowCollector (流收集器) 是 Flow 的中间或终端操作符，它代表一个可以接收 Flow 所发出值的实体。

您通常不需要直接实现这个接口，而是通过函数式（SAM）转换来使用它，例如在 flow.collect { ... } 的 lambda 块中，您所在的上下文就是一个 FlowCollector。

此接口的实现不是线程安全的。

Author

M8Test, [email protected], https://m8test.com

Parameters

收集器可以接收的值的类型。

Functions

also

abstract fun also(block: (ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>) -> Unit): ObjectWrapper<ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>>

对 ObjectWrapper 调用给定的 block 函数，并返回 ObjectWrapper 本身。

apply

abstract fun apply(block: ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>.() -> Unit): ObjectWrapper<ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>>

对 ObjectWrapper 调用给定的 block 函数，并返回 ObjectWrapper 本身。

emit

abstract fun emit(scope: CoroutineScope, value: T): Job

收集（或称“发出”）一个值。

getOrigin

abstract fun getOrigin(): ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>

获取原始的对象.

let

abstract fun <R> let(block: (ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>) -> R): ObjectWrapper<R>?

对 ObjectWrapper 调用给定的 block 函数，并返回 block 函数的结果包装在 ObjectWrapper 中。

run

abstract fun <R> run(block: ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>.() -> R): ObjectWrapper<R>?

对 ObjectWrapper 调用给定的 block 函数，并返回 block 函数的结果包装在 ObjectWrapper 中。

setOrigin

abstract fun setOrigin(origin: ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>)

设置原始对象

takeIf

abstract fun takeIf(predicate: (ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>) -> Boolean): ObjectWrapper<ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>>?

如果 ObjectWrapper 满足给定的 predicate，则返回 ObjectWrapper 本身，否则返回 null 包装在 ObjectWrapper? 中。

takeUnless

abstract fun takeUnless(predicate: (ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>) -> Boolean): ObjectWrapper<ERROR CLASS: Symbol not found for kotlinx.coroutines.flow.FlowCollector<T>>?

如果 ObjectWrapper 不满足给定的 predicate，则返回 ObjectWrapper 本身，否则返回 null 包装在 ObjectWrapper? 中。