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 Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.
-
Field Details
-
INSTANCE
-
-
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 interfaceBackpressureOverflow.Strategy
- Returns:
- true to request drop of the oldest item, false to drop the newest.
-