Hello, I need some advice. I have an observable th...

# rx

[georgiy.shur]

Hello, I need some advice. I have an observable that sometimes emit some items and then I have some operation (flat-mapped API call) in this stream, but I think we can mock it with delay for now for simplicity:

observable.delay(Random(1000).nextLong(), TimeUnit.MILLISECONDS)

What I need is if the new item will arrive while the operation isn't completed for the previous item, the previous one will be dropped (filtered)