Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.util | |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
Modifier and Type | Method and Description |
---|---|
Flowable<T> |
Single.repeatUntil(BooleanSupplier stop)
Re-subscribes to the current Single until the given BooleanSupplier returns true.
|
Observable<T> |
Observable.repeatUntil(BooleanSupplier stop)
Returns an Observable that repeats the sequence of items emitted by the source ObservableSource until
the provided stop function returns true.
|
Flowable<T> |
Maybe.repeatUntil(BooleanSupplier stop)
Returns a Flowable that repeats the sequence of items emitted by the source Maybe until
the provided stop function returns true.
|
Flowable<T> |
Flowable.repeatUntil(BooleanSupplier stop)
Returns a Flowable that repeats the sequence of items emitted by the source Publisher until
the provided stop function returns true.
|
Completable |
Completable.repeatUntil(BooleanSupplier stop)
Returns a Completable that repeatedly subscribes to this Completable so long as the given
stop supplier returns false.
|
Observable<T> |
Observable.retryUntil(BooleanSupplier stop)
Retries until the given stop function returns true.
|
Maybe<T> |
Maybe.retryUntil(BooleanSupplier stop)
Retries until the given stop function returns true.
|
Flowable<T> |
Flowable.retryUntil(BooleanSupplier stop)
Retries until the given stop function returns true.
|
Modifier and Type | Method and Description |
---|---|
static <T> Predicate<T> |
Functions.predicateReverseFor(BooleanSupplier supplier) |
Constructor and Description |
---|
FlowableRepeatUntil(Flowable<T> source,
BooleanSupplier until) |
Constructor and Description |
---|
ObservableRepeatUntil(Observable<T> source,
BooleanSupplier until) |
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static BooleanSupplier |
RxJavaPlugins.getOnBeforeBlocking()
Returns the current blocking handler or null if no custom handler
is set.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnBeforeBlocking(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.
|
Copyright © 2019. All rights reserved.