Uses of Enum Class
io.reactivex.rxjava3.core.BackpressureOverflowStrategy
Packages that use BackpressureOverflowStrategy
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of BackpressureOverflowStrategy in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return BackpressureOverflowStrategyModifier and TypeMethodDescriptionstatic BackpressureOverflowStrategy
Returns the enum constant of this class with the specified name.static BackpressureOverflowStrategy[]
BackpressureOverflowStrategy.values()
Returns an array containing the constants of this enum class, in the order they are declared.Methods in io.reactivex.rxjava3.core with parameters of type BackpressureOverflowStrategyModifier and TypeMethodDescriptionFlowable.onBackpressureBuffer
(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.Flowable.onBackpressureBuffer
(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy, @NonNull Consumer<? super @NonNull T> onDropped) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place. -
Uses of BackpressureOverflowStrategy in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as BackpressureOverflowStrategyModifier and TypeFieldDescription(package private) final BackpressureOverflowStrategy
FlowableOnBackpressureBufferStrategy.OnBackpressureBufferStrategySubscriber.strategy
(package private) final BackpressureOverflowStrategy
FlowableOnBackpressureBufferStrategy.strategy
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BackpressureOverflowStrategyModifierConstructorDescriptionFlowableOnBackpressureBufferStrategy
(Flowable<T> source, long bufferSize, Action onOverflow, BackpressureOverflowStrategy strategy, Consumer<? super T> onDropped) (package private)
OnBackpressureBufferStrategySubscriber
(org.reactivestreams.Subscriber<? super T> actual, Action onOverflow, BackpressureOverflowStrategy strategy, long bufferSize, Consumer<? super T> onDropped)