Package rx

Interface BackpressureOverflow.Strategy

All Known Implementing Classes:
BackpressureOverflow.DropLatest, BackpressureOverflow.DropOldest, BackpressureOverflow.Error
Enclosing class:
BackpressureOverflow

public static interface BackpressureOverflow.Strategy
Represents a callback called when a value is about to be dropped due to lack of downstream requests.
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.
  • Method Details

    • mayAttemptDrop

      boolean mayAttemptDrop() throws MissingBackpressureException
      Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.
      Returns:
      true to request drop of the oldest item, false to drop the newest.
      Throws:
      MissingBackpressureException