kotlin - 根据值(value)减少助焊剂排放？

Question

我有以下变化:

val myFlux = Flux.fromIterable(listOf("A", "A", "B", "C", "C"))

此通量内的元素已排序，通量本身巨大(我们可以假设它是无限的)

我想将其映射到 Flux<String>中，其中每个 String将分别包含 AA B CC。

也可以是 Flux<SomeDomainObject>，其中每个 SomeDomainObject将包含相同的键(例如 AA)

我不能使用 groupBy，因为键数很大。

所需的通量行为:

Answer 1

您可以使用bufferUntil-功能:https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferUntil-java.util.function.Predicate-boolean-

fun<T> newItem(): Predicate<T> {
    var lastItem: T? = null

    return Predicate<T> { newItem ->
        when {
            lastItem == null -> {
                lastItem = newItem
                false
            }
            lastItem != newItem -> {
                lastItem = newItem
                true
            }
            else -> false
        }
    }
}

fun main(args: Array<String>) {
    val flux = Flux.just("A", "A", "B", "C", "C")
    val buffered = flux.bufferUntil(newItem(), true).map { it.joinToString("") }

    buffered.subscribe {
        println(it)
    }
}