Uses of Interface
io.reactivex.rxjava3.functions.BooleanSupplier

Packages that use BooleanSupplier

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.functions
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.plugins	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 BooleanSupplier

Modifier and Type	Method	Description
@NonNull Completable	Completable.repeatUntil(@NonNull BooleanSupplier stop)	Returns a Completable that repeatedly subscribes to this Completable so long as the given stop BooleanSupplier returns false.
@NonNull Flowable<T>	Flowable.repeatUntil(@NonNull BooleanSupplier stop)	Returns a Flowable that repeats the sequence of items emitted by the current Flowable until the provided stop function returns true.
@NonNull Flowable<T>	Maybe.repeatUntil(@NonNull BooleanSupplier stop)	Returns a Flowable that repeats the sequence of items emitted by the current Maybe until the provided stop function returns true.
@NonNull Observable<T>	Observable.repeatUntil(@NonNull BooleanSupplier stop)	Returns an Observable that repeats the sequence of items emitted by the current Observable until the provided stop function returns true.
@NonNull Flowable<T>	Single.repeatUntil(@NonNull BooleanSupplier stop)	Re-subscribes to the current Single until the given BooleanSupplier returns true and emits the success items as a Flowable sequence.
@NonNull Completable	Completable.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.
@NonNull Flowable<T>	Flowable.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.
@NonNull Maybe<T>	Maybe.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.
@NonNull Observable<T>	Observable.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.
@NonNull Single<T>	Single.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.

Uses of BooleanSupplier in io.reactivex.rxjava3.internal.functions

Fields in io.reactivex.rxjava3.internal.functions declared as BooleanSupplier

Modifier and Type	Field	Description
(package private) BooleanSupplier	Functions.BooleanSupplierPredicateReverse.supplier

Methods in io.reactivex.rxjava3.internal.functions with parameters of type BooleanSupplier

Modifier and Type	Method	Description
static <T> Predicate<T>	Functions.predicateReverseFor(BooleanSupplier supplier)

Constructors in io.reactivex.rxjava3.internal.functions with parameters of type BooleanSupplier

Constructor	Description
BooleanSupplierPredicateReverse(BooleanSupplier supplier)

Uses of BooleanSupplier in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement BooleanSupplier

Modifier and Type	Class	Description
(package private) static class	FlowableBuffer.PublisherBufferOverlappingSubscriber<T,C extends java.util.Collection<? super T>>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as BooleanSupplier

Modifier and Type	Field	Description
(package private) BooleanSupplier	FlowableRepeatUntil.RepeatSubscriber.stop
(package private) BooleanSupplier	FlowableRepeatUntil.until

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BooleanSupplier

Constructor	Description
FlowableRepeatUntil(Flowable<T> source, BooleanSupplier until)
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 BooleanSupplier

Modifier and Type	Field	Description
(package private) BooleanSupplier	ObservableRepeatUntil.RepeatUntilObserver.stop
(package private) BooleanSupplier	ObservableRepeatUntil.until

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type BooleanSupplier

Constructor	Description
ObservableRepeatUntil(Observable<T> source, BooleanSupplier until)
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 BooleanSupplier

Modifier and Type	Method	Description
(package private) static boolean	QueueDrainHelper.isCancelled(BooleanSupplier cancelled)
static <T> void	QueueDrainHelper.postComplete(org.reactivestreams.Subscriber<? super T> actual, java.util.Queue<T> queue, java.util.concurrent.atomic.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, java.util.Queue<T> queue, java.util.concurrent.atomic.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, java.util.Queue<T> queue, java.util.concurrent.atomic.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 BooleanSupplier

Modifier and Type	Field	Description
(package private) static @Nullable BooleanSupplier	RxJavaPlugins.onBeforeBlocking

Methods in io.reactivex.rxjava3.plugins that return BooleanSupplier

Modifier and Type	Method	Description
static @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 BooleanSupplier

Modifier and Type	Method	Description
static 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.