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 classDrop most recent items, but notonErrornor unsubscribe from source (as {code OperatorOnBackpressureDrop}).(package private) static classDrop oldest items from the buffer making room for newer ones.(package private) static classonErrora MissingBackpressureException and unsubscribe from source.Fields in rx declared as BackpressureOverflow.StrategyModifier and TypeFieldDescriptionstatic final BackpressureOverflow.StrategyBackpressureOverflow.ON_OVERFLOW_DEFAULTBy default, signal a MissingBackressureException due to lack of requests.static final BackpressureOverflow.StrategyBackpressureOverflow.ON_OVERFLOW_DROP_LATESTDrop the latest value.static final BackpressureOverflow.StrategyBackpressureOverflow.ON_OVERFLOW_DROP_OLDESTDrop the oldest value in the buffer.static final BackpressureOverflow.StrategyBackpressureOverflow.ON_OVERFLOW_ERRORSignal 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.StrategyOperatorOnBackpressureBuffer.BufferSubscriber.overflowStrategyprivate final BackpressureOverflow.StrategyOperatorOnBackpressureBuffer.overflowStrategyConstructors 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: