Uses of Interface
rx.BackpressureOverflow.Strategy
-
Packages that use BackpressureOverflow.Strategy Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.internal.operators 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.Strategy Modifier and Type Class Description (package private) static classBackpressureOverflow.DropLatestDrop most recent items, but notonErrornor unsubscribe from source (as {code OperatorOnBackpressureDrop}).(package private) static classBackpressureOverflow.DropOldestDrop oldest items from the buffer making room for newer ones.(package private) static classBackpressureOverflow.ErroronErrora MissingBackpressureException and unsubscribe from source.Fields in rx declared as BackpressureOverflow.Strategy Modifier and Type Field Description static BackpressureOverflow.StrategyBackpressureOverflow. ON_OVERFLOW_DEFAULTBy default, signal a MissingBackressureException due to lack of requests.static BackpressureOverflow.StrategyBackpressureOverflow. ON_OVERFLOW_DROP_LATESTDrop the latest value.static BackpressureOverflow.StrategyBackpressureOverflow. ON_OVERFLOW_DROP_OLDESTDrop the oldest value in the buffer.static BackpressureOverflow.StrategyBackpressureOverflow. ON_OVERFLOW_ERRORSignal a MissingBackressureException due to lack of requests.Methods in rx with parameters of type BackpressureOverflow.Strategy Modifier and Type Method Description 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.Strategy Modifier and Type Field Description private BackpressureOverflow.StrategyOperatorOnBackpressureBuffer.BufferSubscriber. overflowStrategyprivate BackpressureOverflow.StrategyOperatorOnBackpressureBuffer. overflowStrategyConstructors in rx.internal.operators with parameters of type BackpressureOverflow.Strategy Constructor Description BufferSubscriber(Subscriber<? super T> child, java.lang.Long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)Construct a new instance feeding the following behavior config:
-