<@U0BFDUP0E> - it was buffer. The following achie...

# rx

[zak.taccardi]

@jw - it was buffer. The following achieved what I needed

fun <T, R> Observable<T>.scanMap(func2: (T?, T) -> R): Observable<R> {
    return this.startWith(null as T?)
            .buffer(2, 1)
            .map { func2.invoke(it[0], it[1]) }
}

https://gist.github.com/ZakTaccardi/06512860c37c732da165f6b4c2be40a5