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