Uses of Interface
rx.BackpressureOverflow.Strategy
Packages that use BackpressureOverflow.Strategy
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of BackpressureOverflow.Strategy in rx
Classes in rx that implement BackpressureOverflow.StrategyModifier 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.Fields in rx declared as BackpressureOverflow.StrategyModifier and TypeFieldDescriptionstatic final BackpressureOverflow.Strategy
BackpressureOverflow.ON_OVERFLOW_DEFAULT
By default, signal a MissingBackressureException due to lack of requests.static final BackpressureOverflow.Strategy
BackpressureOverflow.ON_OVERFLOW_DROP_LATEST
Drop the latest value.static final BackpressureOverflow.Strategy
BackpressureOverflow.ON_OVERFLOW_DROP_OLDEST
Drop the oldest value in the buffer.static final BackpressureOverflow.Strategy
BackpressureOverflow.ON_OVERFLOW_ERROR
Signal a MissingBackressureException due to lack of requests.Methods in rx with parameters of type BackpressureOverflow.StrategyModifier and TypeMethodDescriptionfinal Observable
<T> Observable.onBackpressureBuffer
(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy) Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted. -
Uses of BackpressureOverflow.Strategy in rx.internal.operators
Fields in rx.internal.operators declared as BackpressureOverflow.StrategyModifier and TypeFieldDescriptionprivate final BackpressureOverflow.Strategy
OperatorOnBackpressureBuffer.BufferSubscriber.overflowStrategy
private final BackpressureOverflow.Strategy
OperatorOnBackpressureBuffer.overflowStrategy
Constructors in rx.internal.operators with parameters of type BackpressureOverflow.StrategyModifierConstructorDescriptionBufferSubscriber
(Subscriber<? super T> child, Long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy) OperatorOnBackpressureBuffer
(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy) Construct a new instance feeding the following behavior config: