onBackpressureXXX

[headinthebox]

Change onBackpressureDrop to same style as onBackpressureBuffer.

onBackpressureBuffer()
Instructs an Observable that is emitting items faster than its observer can consume them to buffer these items indefinitely until they can be emitted.

onBackpressureDrop()
Use this operator when the upstream does not natively support backpressure and you wish to drop onNext when unable to handle further events.