Package rx
Class BackpressureOverflow.Error
- java.lang.Object
-
- rx.BackpressureOverflow.Error
-
- All Implemented Interfaces:
BackpressureOverflow.Strategy
- Enclosing class:
- BackpressureOverflow
static class BackpressureOverflow.Error extends java.lang.Object implements BackpressureOverflow.Strategy
onError
a MissingBackpressureException and unsubscribe from source.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) static BackpressureOverflow.Error
INSTANCE
-
Constructor Summary
Constructors Modifier Constructor Description private
Error()
-
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.Error INSTANCE
-
-
Method Detail
-
mayAttemptDrop
public boolean mayAttemptDrop() throws MissingBackpressureException
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.
- Throws:
MissingBackpressureException
-
-