Hey, I want to have a scan function like this: `fu...

# rx

[thanh]

Hey, I want to have a scan function like this: fun Observable<T>.scan(initialValueProvider: (T) -> R, accumulator: (R, T) -> R). Basically it uses initialValueProvider for the first emitted value, and uses accumulator for later values.