PreprocessingProperties

Items 中通过预处理函数所配置的预处理值。 如果值为 -1 则代表未配置。

Properties

Link copied to clipboard
val batch: Int
Link copied to clipboard
val limit: Int
Link copied to clipboard
val offset: Int

Extensions

Link copied to clipboard
fun <E> Items.PreprocessingProperties.effectedFlow(block: suspend FlowCollector<E>.() -> Unit): Flow<E>

构建一个flow,并将当前 Items.PreprocessingProperties 作用于最终的 Flow 中。

Link copied to clipboard

构建一个sequence,并将当前 Items.PreprocessingProperties 作用于最终的 Sequence 中。

Link copied to clipboard
fun <E> Items.PreprocessingProperties.effectOn(flow: Flow<E>): Flow<E>

Items.PreprocessingProperties 作用于目标 Flow 中。

Items.PreprocessingProperties 作用于目标 Sequence 中。

Items.PreprocessingProperties 作用于目标 Stream 中。

fun <E> Items.PreprocessingProperties.effectOn(iter: ChannelIterator<E>): ChannelIterator<E>

将一个 Items.PreprocessingProperties 作用于目标 ChannelIterator 上。