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
andCompletable
; 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 handlerRxJavaPlugins
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 aCompletable
that repeatedly subscribes to thisCompletable
so long as the given stopBooleanSupplier
returnsfalse
.@NonNull Flowable<T>
Flowable. repeatUntil(@NonNull BooleanSupplier stop)
Returns aFlowable
that repeats the sequence of items emitted by the currentFlowable
until the provided stop function returnstrue
.@NonNull Flowable<T>
Maybe. repeatUntil(@NonNull BooleanSupplier stop)
Returns aFlowable
that repeats the sequence of items emitted by the currentMaybe
until the provided stop function returnstrue
.@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
.@NonNull Flowable<T>
Single. repeatUntil(@NonNull BooleanSupplier stop)
Re-subscribes to the currentSingle
until the givenBooleanSupplier
returnstrue
and emits the success items as aFlowable
sequence.@NonNull Completable
Completable. retryUntil(@NonNull BooleanSupplier stop)
Retries until the given stop function returnstrue
.@NonNull Flowable<T>
Flowable. retryUntil(@NonNull BooleanSupplier stop)
Retries until the given stop function returnstrue
.@NonNull Maybe<T>
Maybe. retryUntil(@NonNull BooleanSupplier stop)
Retries until the given stop function returnstrue
.@NonNull Observable<T>
Observable. retryUntil(@NonNull BooleanSupplier stop)
Retries until the given stop function returnstrue
.@NonNull Single<T>
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 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.
-