Package rx
Class BackpressureOverflow
- java.lang.Object
-
- rx.BackpressureOverflow
-
@Experimental public final class BackpressureOverflow extends java.lang.Object
Generic strategy and default implementations to deal with backpressure buffer overflows.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
BackpressureOverflow.DropLatest
Drop most recent items, but notonError
nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).(package private) static class
BackpressureOverflow.DropOldest
Drop oldest items from the buffer making room for newer ones.(package private) static class
BackpressureOverflow.Error
onError
a MissingBackpressureException and unsubscribe from source.static interface
BackpressureOverflow.Strategy
Represents a callback called when a value is about to be dropped due to lack of downstream requests.
-
Field Summary
Fields Modifier and Type Field Description static BackpressureOverflow.Strategy
ON_OVERFLOW_DEFAULT
By default, signal a MissingBackressureException due to lack of requests.static BackpressureOverflow.Strategy
ON_OVERFLOW_DROP_LATEST
Drop the latest value.static BackpressureOverflow.Strategy
ON_OVERFLOW_DROP_OLDEST
Drop the oldest value in the buffer.static BackpressureOverflow.Strategy
ON_OVERFLOW_ERROR
Signal a MissingBackressureException due to lack of requests.
-
Constructor Summary
Constructors Constructor Description BackpressureOverflow()
-
-
-
Field Detail
-
ON_OVERFLOW_ERROR
public static final BackpressureOverflow.Strategy ON_OVERFLOW_ERROR
Signal a MissingBackressureException due to lack of requests.
-
ON_OVERFLOW_DEFAULT
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DEFAULT
By default, signal a MissingBackressureException due to lack of requests.
-
ON_OVERFLOW_DROP_OLDEST
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_OLDEST
Drop the oldest value in the buffer.
-
ON_OVERFLOW_DROP_LATEST
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_LATEST
Drop the latest value.
-
-