time.Sleep(200 * time.Millisecond)so it's just able to consume
WithBufferBackpressureStrategyto create a buffered channel of 3 items so it can buffer and then consume
1, 2, 3
They introduced specialized observable - Flowable. Thanks to flowable introduction, the back pressure is applied properly through whole pipe.
What do we have exactly in RxJava?
Observable for cold observables,
Flowable for hot observable with back-pressure and
ConnectableObservable for hot observables without backpressure starting to publish once