Package rx
Class BackpressureOverflow.DropLatest
- java.lang.Object
-
- rx.BackpressureOverflow.DropLatest
-
- All Implemented Interfaces:
BackpressureOverflow.Strategy
- Enclosing class:
- BackpressureOverflow
static class BackpressureOverflow.DropLatest extends java.lang.Object implements BackpressureOverflow.Strategy
Drop most recent items, but notonError
nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).
-
-
Field Summary
Fields Modifier and Type Field Description (package private) static BackpressureOverflow.DropLatest
INSTANCE
-
Constructor Summary
Constructors Modifier Constructor Description private
DropLatest()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
mayAttemptDrop()
Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.
-
-
-
Field Detail
-
INSTANCE
static final BackpressureOverflow.DropLatest INSTANCE
-
-
Method Detail
-
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 interfaceBackpressureOverflow.Strategy
- Returns:
- true to request drop of the oldest item, false to drop the newest.
-
-