Flowable

We may call Flowables a backpressured version of Observables. Probably, the only difference between Flowables and Observables is that Flowable takes backpressure into consideration. Observable does not. That's it. Flowable hosts the default buffer size of 128 elements for operators, so, when the consumer is taking time, the emitted items may wait in the buffer.

Note that Flowables were added in ReactiveX 2.x (RxKotlin 2.X), and the previous versions don't include them. Instead, in previous versions, Observables was retrofitted to support backpressure that caused many unexpected MissingBackpressureException. Here is the release note if you are interested: https://github.com/ReactiveX/RxJava/wiki/What%27s-different-in-2.0#observable-and-flowable ...

Get Reactive Programming in Kotlin now with the O’Reilly learning platform.

O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.