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 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.Fields in rx declared as BackpressureOverflow.Strategy Modifier and Type Field Description static BackpressureOverflow.Strategy
BackpressureOverflow. ON_OVERFLOW_DEFAULT
By default, signal a MissingBackressureException due to lack of requests.static BackpressureOverflow.Strategy
BackpressureOverflow. ON_OVERFLOW_DROP_LATEST
Drop the latest value.static BackpressureOverflow.Strategy
BackpressureOverflow. ON_OVERFLOW_DROP_OLDEST
Drop the oldest value in the buffer.static BackpressureOverflow.Strategy
BackpressureOverflow. ON_OVERFLOW_ERROR
Signal 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.Strategy
OperatorOnBackpressureBuffer.BufferSubscriber. overflowStrategy
private BackpressureOverflow.Strategy
OperatorOnBackpressureBuffer. overflowStrategy
Constructors 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:
-