<@U0BR3D202> So basically there are two ways of ha...

# rx

[bicx]

@nhaarman So basically there are two ways of handling backpressure (items being emitted faster than you can handle them): accumulating items and then emitting them as you can process them via some sort of buffer, or just avoiding backpressure entirely by ignoring values that happen during a time interval (like throttleFirst()). Other such accumulating operators are buffer() as well as window(). You can read more here: http://reactivex.io/documentation/operators/backpressure.html