Can I receive most recently two value when a new v...

# flow

[Simon Lin]

Can I receive most recently two value when a new value emit? for example:

emit: 1, 2, 3, 4, 5, 6
downstream receive: [initValue, 1] [1, 2] [2, 3] [3, 4] [4, 5] [5, 6]

[ephemient]

nothing built in, but writing your own operator is easy:

fun <T> Flow<T>.zipWithNext(initValue: T): Flow<Pair<T, T>> = flow {
    var lastValue = initValue
    collect {
        emit(lastValue to it)
        lastValue = it
    }
}

flowOf(1, 2, 3, 4, 5, 6).zipWithNext(0).toList() ==
    listOf(0 to 1, 1 to 2, 2 to 3, 3 to 4, 4 to 5, 5 to 6)

[ephemient]

could even write something more general like

fun <T> Flow<T>.windowed(
    size: Int,
    step: Int = 1,
    partialWindows: Boolean = false
): Flow<List<T>> {
    require(size > 0 && step > 0)
    return flow {
        val window = ArrayDeque<T>(size)
        var count = 0
        collect {
            if (window.size >= size) window.removeFirst()
            window.add(it)
            if (window.size == size && count == 0) emit(window.toList())
            count = (count + 1) % step
        }
        if (partialWindows) {
            while (window.size > 1) {
                window.removeFirst()
                if (count == 0) emit(window.toList())
                count = (count + 1) % step
        	}
        }
    }
}

flowOf(1, 2, 3, 4, 5, 6).onStart { emit(0) }.windowed(2).toList() ==
    listOf(listOf(0, 1), listOf(1, 2), listOf(2, 3), listOf(3, 4), listOf(4, 5), listOf(5, 6))

[Natsuki(开元米粉实力代购)]

the more general format is built-in fold

listOf(1, 2, 3).asFlow().fold(0) { prev, ele ->
        println(prev to ele)
        ele
    }

[ephemient]

if you're working on List<> then you already have .zipWithNext() and .windowed() in stdlib 🙂

[Simon Lin]

Another way: https://github.com/Kotlin/kotlinx.coroutines/issues/1767#issuecomment-577158308