In the previous chapter, we learned about different operators that intercept rapidly firing emissions and either consolidate or omit them to decrease the emissions passed downstream. But for most cases where a source is producing emissions faster than the downstream can process them, it is better to proactively make the source slow down in the first place and emit at a pace that agrees with the downstream operations. This is known as backpressure or flow control, and it can be enabled by using a Flowable instead of an Observable. This will be the core type that we work with in this chapter, and we will learn about the right times to leverage it in our applications. We will cover the following topics in this chapter:
- Understanding backpressure
- Flowable and Subscriber
- Using Flowable.create()
- Interoperating Observables and Flowables
- Backpressure operators...
