Tolriq
12/08/2020, 10:02 AMfun <T> StateFlow<T>.withPrevious(): Flow<Pair<T?, T>> {
return flow {
var previous: T? = null
this@withPrevious.onEach {
emit(Pair(previous, it))
previous = it
}.collect()
}
}
Circusmagnus
12/08/2020, 12:37 PMfun <T> Flow<T>.withPrevious(): Flow<Pair<T?, T>> {
return flow {
var previous: T? = null
collect { value ->
emit(Pair(previous, it))
previous = it
}
}
}
windowed
operator for that once: https://github.com/Kotlin/kotlinx.coroutines/pull/1558Tolriq
12/08/2020, 1:59 PM