Uses of Interface
io.reactivex.rxjava3.functions.BooleanSupplier
Packages that use BooleanSupplier
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.-
Uses of BooleanSupplier in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type BooleanSupplierModifier and TypeMethodDescriptionfinal @NonNull Completable
Completable.repeatUntil
(@NonNull BooleanSupplier stop) Returns aCompletable
that repeatedly subscribes to thisCompletable
so long as the given stopBooleanSupplier
returnsfalse
.Flowable.repeatUntil
(@NonNull BooleanSupplier stop) Returns aFlowable
that repeats the sequence of items emitted by the currentFlowable
until the provided stop function returnstrue
.Maybe.repeatUntil
(@NonNull BooleanSupplier stop) Returns aFlowable
that repeats the sequence of items emitted by the currentMaybe
until the provided stop function returnstrue
.final @NonNull Observable
<T> Observable.repeatUntil
(@NonNull BooleanSupplier stop) Returns anObservable
that repeats the sequence of items emitted by the currentObservable
until the provided stop function returnstrue
.Single.repeatUntil
(@NonNull BooleanSupplier stop) Re-subscribes to the currentSingle
until the givenBooleanSupplier
returnstrue
and emits the success items as aFlowable
sequence.final @NonNull Completable
Completable.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
.Flowable.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
.Maybe.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
.final @NonNull Observable
<T> Observable.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
.Single.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
. -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.functions
Fields in io.reactivex.rxjava3.internal.functions declared as BooleanSupplierModifier and TypeFieldDescription(package private) final BooleanSupplier
Functions.BooleanSupplierPredicateReverse.supplier
Methods in io.reactivex.rxjava3.internal.functions with parameters of type BooleanSupplierModifier and TypeMethodDescriptionstatic <T> Predicate
<T> Functions.predicateReverseFor
(BooleanSupplier supplier) Constructors in io.reactivex.rxjava3.internal.functions with parameters of type BooleanSupplierModifierConstructorDescription(package private)
-
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement BooleanSupplierModifier and TypeClassDescription(package private) static final class
FlowableBuffer.PublisherBufferOverlappingSubscriber<T,
C extends Collection<? super T>> Fields in io.reactivex.rxjava3.internal.operators.flowable declared as BooleanSupplierModifier and TypeFieldDescription(package private) final BooleanSupplier
FlowableRepeatUntil.RepeatSubscriber.stop
(package private) final BooleanSupplier
FlowableRepeatUntil.until
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BooleanSupplierModifierConstructorDescriptionFlowableRepeatUntil
(Flowable<T> source, BooleanSupplier until) (package private)
RepeatSubscriber
(org.reactivestreams.Subscriber<? super T> actual, BooleanSupplier until, SubscriptionArbiter sa, org.reactivestreams.Publisher<? extends T> source) -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as BooleanSupplierModifier and TypeFieldDescription(package private) final BooleanSupplier
ObservableRepeatUntil.RepeatUntilObserver.stop
(package private) final BooleanSupplier
ObservableRepeatUntil.until
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type BooleanSupplierModifierConstructorDescriptionObservableRepeatUntil
(Observable<T> source, BooleanSupplier until) (package private)
RepeatUntilObserver
(Observer<? super T> actual, BooleanSupplier until, SequentialDisposable sd, ObservableSource<? extends T> source) -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type BooleanSupplierModifier and TypeMethodDescription(package private) static boolean
QueueDrainHelper.isCancelled
(BooleanSupplier cancelled) static <T> void
QueueDrainHelper.postComplete
(org.reactivestreams.Subscriber<? super T> actual, Queue<T> queue, AtomicLong state, BooleanSupplier isCancelled) Signals the completion of the main sequence and switches to post-completion replay mode.(package private) static <T> boolean
QueueDrainHelper.postCompleteDrain
(long n, org.reactivestreams.Subscriber<? super T> actual, Queue<T> queue, AtomicLong state, BooleanSupplier isCancelled) Drains the queue based on the outstanding requests in post-completed mode (only!).static <T> boolean
QueueDrainHelper.postCompleteRequest
(long n, org.reactivestreams.Subscriber<? super T> actual, Queue<T> queue, AtomicLong state, BooleanSupplier isCancelled) Accumulates requests (not validated) and handles the completed mode draining of the queue based on the requests. -
Uses of BooleanSupplier in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins declared as BooleanSupplierModifier and TypeFieldDescription(package private) static @Nullable BooleanSupplier
RxJavaPlugins.onBeforeBlocking
Methods in io.reactivex.rxjava3.plugins that return BooleanSupplierModifier and TypeMethodDescriptionstatic @Nullable BooleanSupplier
RxJavaPlugins.getOnBeforeBlocking()
Returns the current blocking handler or null if no custom handler is set.Methods in io.reactivex.rxjava3.plugins with parameters of type BooleanSupplierModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setOnBeforeBlocking
(@Nullable BooleanSupplier handler) Set the handler that is called when an operator attempts a blocking await; the handler should return true to prevent the blocking and to signal an IllegalStateException instead.