Uses of Class
io.reactivex.rxjava3.core.BackpressureOverflowStrategy
-
Packages that use BackpressureOverflowStrategy Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.operators.flowable -
-
Uses of BackpressureOverflowStrategy in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return BackpressureOverflowStrategy Modifier and Type Method Description static BackpressureOverflowStrategy
BackpressureOverflowStrategy. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static BackpressureOverflowStrategy[]
BackpressureOverflowStrategy. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in io.reactivex.rxjava3.core with parameters of type BackpressureOverflowStrategy Modifier and Type Method Description @NonNull Flowable<T>
Flowable. 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.@NonNull Flowable<T>
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 BackpressureOverflowStrategy Modifier and Type Field Description (package private) BackpressureOverflowStrategy
FlowableOnBackpressureBufferStrategy.OnBackpressureBufferStrategySubscriber. strategy
(package private) BackpressureOverflowStrategy
FlowableOnBackpressureBufferStrategy. strategy
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BackpressureOverflowStrategy Constructor Description FlowableOnBackpressureBufferStrategy(Flowable<T> source, long bufferSize, Action onOverflow, BackpressureOverflowStrategy strategy, Consumer<? super T> onDropped)
OnBackpressureBufferStrategySubscriber(org.reactivestreams.Subscriber<? super T> actual, Action onOverflow, BackpressureOverflowStrategy strategy, long bufferSize, Consumer<? super T> onDropped)
-