Reactive Programming in Kotlin

Learning Buffer, Throttle, and Window operators

So far, we have learned about backpressure. We slowed down the source, dropped items, or used buffer, which will hold items until the consumer consumes it; however, will all these suffice? While handling backpressure at the downstream is not a good solution always, we cannot always slow down the source as well.

While using Observable.interval/Flowable.interval, you cannot slow down the source. A stop gap could be some operators that would somehow allow us to process the emissions simultaneously.

There are the three operators that could help us in that way:

• Buffer
• Throttle
• Window