okay, in case somebody needs it, here is a extensi...

# rx

[ursus]

okay, in case somebody needs it, here is a extension function

fun <T> Observable<T>.withCachedValues(cache: Array<T?>): Observable<Array<T?>> {
    return scan(cache) { accumulator, new ->
        val size = accumulator.size
        System.arraycopy(accumulator, 1, accumulator, 0, size - 1);
        accumulator[size - 1] = new
        accumulator
    }.skip(1)
}