Package rx

Class BackpressureOverflow.DropLatest

java.lang.Object
rx.BackpressureOverflow.DropLatest
All Implemented Interfaces:
BackpressureOverflow.Strategy
Enclosing class:
BackpressureOverflow

static class BackpressureOverflow.DropLatest extends Object implements BackpressureOverflow.Strategy
Drop most recent items, but not onError nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).
  • Field Details

  • Constructor Details

    • DropLatest

      private DropLatest()
  • Method Details

    • mayAttemptDrop

      public boolean mayAttemptDrop()
      Description copied from interface: BackpressureOverflow.Strategy
      Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.
      Specified by:
      mayAttemptDrop in interface BackpressureOverflow.Strategy
      Returns:
      true to request drop of the oldest item, false to drop the newest.