BackpressureStrategy.MISSING and onBackpressureXXX()

BackpressureStrategy.MISSING implies that it'll not implement any backpressure strategy, so you need to explicitly tell Flowable which backpressure strategy to follow. The onBackpressureXXX() operators help you achieve the same, while providing you with some additional configuration options.

There are mainly three types of onBackpressureXXX() operators available:

  • onBackpressureBuffer()
  • onBackpressureDrop()
  • onBackpressureLatest()

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.