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 CompletableCompletable.repeatUntil(@NonNull BooleanSupplier stop) Returns aCompletablethat repeatedly subscribes to thisCompletableso long as the given stopBooleanSupplierreturnsfalse.Flowable.repeatUntil(@NonNull BooleanSupplier stop) Returns aFlowablethat repeats the sequence of items emitted by the currentFlowableuntil the provided stop function returnstrue.Maybe.repeatUntil(@NonNull BooleanSupplier stop) Returns aFlowablethat repeats the sequence of items emitted by the currentMaybeuntil the provided stop function returnstrue.final @NonNull Observable<T> Observable.repeatUntil(@NonNull BooleanSupplier stop) Returns anObservablethat repeats the sequence of items emitted by the currentObservableuntil the provided stop function returnstrue.Single.repeatUntil(@NonNull BooleanSupplier stop) Re-subscribes to the currentSingleuntil the givenBooleanSupplierreturnstrueand emits the success items as aFlowablesequence.final @NonNull CompletableCompletable.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
Methods in io.reactivex.rxjava3.internal.functions with parameters of type BooleanSupplierModifier and TypeMethodDescriptionstatic <T> Predicate<T> Functions.predicateReverseFor(BooleanSupplier supplier) -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.operators.flowable
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BooleanSupplier -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.operators.observable
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type BooleanSupplier -
Uses of BooleanSupplier in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type BooleanSupplierModifier and TypeMethodDescriptionstatic <T> voidQueueDrainHelper.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.static <T> booleanQueueDrainHelper.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
Methods in io.reactivex.rxjava3.plugins that return BooleanSupplierModifier and TypeMethodDescriptionstatic @Nullable BooleanSupplierRxJavaPlugins.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 voidRxJavaPlugins.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.