获取流程中的最新和先前的值

Question

我需要处理流程收集中的当前和以前的值，因此我需要一些这样的运算符：

----A----------B-------C-----|--->

---(null+A)---(A+B)---(B+C)--|--->

一个想法是类似的：

fun <T: Any> Flow<T>.withPrevious(): Flow<Pair<T?, T>> = flow {
    var prev: T? = null
    [email protected] {
        emit(prev to it)
        prev = it
    }
}

但是，这种方式无法控制第一个流的上下文。有更灵活的解决方案吗？

Answer 1

There's an operator which makes this very easy: runningFold

data class History<T>(val previous: T?, val current: T)

// emits null, History(null,1), History(1,2)...
fun <T> Flow<T>.runningHistory(): Flow<History<T>?> =
    runningFold(
        initial = null as (History<T>?),
        operation = { accumulator, new -> History(accumulator?.current, new) }
    )

// doesn't emit until first value History(null,1), History(1,2)...
fun <T> Flow<T>.runningHistoryAlternative(): Flow<History<T>> =
    runningHistory().filterNotNull()

可能需要调整无效以适合您的用途酶

您 显性

Answer 2

Flow是顺序的，因此您可以使用变量存储上一个值：

coroutineScope.launch {
    var prevValue = null
    flow.collect { newValue ->
        // use prevValue and newValue here
        ...
        // update prevValue
        prevValue = newValue
    }
}

Answer 3

我认为您可以使用RunningFold非常轻松地做到这一点，因为使用它，您可以使用折叠操作将流动转换为另一个流程。 IS是因为RunningFold确实将所有内容都折叠成一个值，例如fold。取而代之的是，它在作为所有突变的历史上工作之间保持了所有步骤。您唯一需要关注的是，每个返回的值必须是一对，第一个值必须为null，并且第一对必须允许左值中的null。允许null作为蓄能器，还意味着必须将该值滤出。

粗略地，您需要遵循这样的示例：

val initial: Pair<String?, String>? = null
val allPairs = flow {
    emit("Oyster")
    emit("Clam")
    emit("Crab")
}.runningFold(initial) { lastPair, next ->
    lastPair?.run {
        val (_, last) = this
        last to next
    } ?: (null to next)

}.filterNotNull()
allPairs.collect {
    println(it)
}

这样，您就不需要创建运营商类型，因为您的运营商类已经是Pair Pair类。

您可以使用fold等测试差异：

val initial: Pair<String?, String>? = null
val pair = flow {
    emit("Oyster")
    emit("Clam")
    emit("Crab")
}.fold(initial) { lastPair, next ->
    lastPair?.run {
        val (_, last) = this
        last to next
    } ?: (null to next)

}
println(pair)

结帐有关折叠的更多信息以及此处的不同形式：

1. fold

2. ：//kotlinlang.org/api/latest/jvm/stdlib/kotlin.collections/running-fold.html“ rel =“ nofollow noreferrer”> runningfold

3. ​“ https://kotlinlang.org/api/latest/jvm/stdlib/kotlin.collections” rel =“ nofollow noreferrer”> kotlin.collections.collections