public abstract class Nono
extends java.lang.Object
implements org.reactivestreams.Publisher<java.lang.Void>
Since this type never emits any value, the implementations ignore the downstream request and emit the terminal events even if there was no request (which is allowed by the Reactive-Streams specification).
Since there is no bottom type in Java (that is T is a subtype of all other types), Nono implements the Publisher interface via the Void type parameter.
| Constructor and Description |
|---|
Nono() |
| Modifier and Type | Method and Description |
|---|---|
static Nono |
amb(java.lang.Iterable<? extends Nono> sources)
Returns a Nono that terminates when the first Nono from the
sources sequence terminates.
|
static Nono |
ambArray(Nono... sources)
Returns a Nono that terminates when the first Nono from the
array terminates.
|
Nono |
andThen(Nono other) |
<T> io.reactivex.Flowable<T> |
andThen(org.reactivestreams.Publisher<? extends T> other) |
java.lang.Throwable |
blockingAwait()
Blockingly await indefinitely the termination of this Nono and return
the Throwable if this Nono terminated with an error, null
otherwise.
|
java.lang.Throwable |
blockingAwait(long timeout,
java.util.concurrent.TimeUnit unit)
Blockingly await for the given timeout the termination of this Nono and return
the Throwable if this Nono terminated with an error, null
otherwise.
|
void |
blockingSubscribe(io.reactivex.functions.Action onComplete)
Block until this Nono completes and call the Action on the thread
where the blocking happens.
|
void |
blockingSubscribe(io.reactivex.functions.Action onComplete,
io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)
Block until this Nono terminates and call the Action or Consumer
depending on the terminal event on the thread where the blocking
happens.
|
static int |
bufferSize()
Returns the default buffer or prefetch size.
|
static Nono |
complete()
Returns a Nono that completes normally.
|
Nono |
compose(io.reactivex.functions.Function<? super Nono,? extends Nono> composer)
Compose operators fluently via a function callback that returns a Nono for
this Nono.
|
static Nono |
concat(java.lang.Iterable<? extends Nono> sources)
Runs the Nono sources one after the other.
|
static Nono |
concat(org.reactivestreams.Publisher<? extends Nono> sources)
Runs the Nono sources emitted by the Publisher one after the other.
|
static Nono |
concat(org.reactivestreams.Publisher<? extends Nono> sources,
int prefetch)
Runs the Nono sources emitted by the Publisher one after the other,
prefetching the given number of Nono sources.
|
static Nono |
concatArray(Nono... sources)
Runs the Nono sources one after the other.
|
static Nono |
concatArrayDelayError(Nono... sources)
Runs the Nono sources one after the other, delaying errors from them
till all sources have terminated.
|
static Nono |
concatDelayError(java.lang.Iterable<? extends Nono> sources)
Runs the Nono sources one after the other, delaying errors from them
till all sources have terminated.
|
static Nono |
concatDelayError(org.reactivestreams.Publisher<? extends Nono> sources)
Runs the Nono sources emitted by the Publisher, one after the other, delaying errors from them
till all sources have terminated.
|
static Nono |
concatDelayError(org.reactivestreams.Publisher<? extends Nono> sources,
int prefetch,
boolean tillTheEnd)
Runs the Nono sources emitted by the Publisher, one after the other, delaying errors from them
till all sources have terminated and prefetching Nonos from the upstream.
|
static Nono |
defer(java.util.concurrent.Callable<? extends Nono> supplier)
Defers the creation of the actual Nono instance until a subscriber
subscribes.
|
Nono |
delay(long delay,
java.util.concurrent.TimeUnit unit) |
Nono |
delay(long delay,
java.util.concurrent.TimeUnit unit,
io.reactivex.Scheduler scheduler) |
Nono |
delaySubscription(long delay,
java.util.concurrent.TimeUnit unit) |
Nono |
delaySubscription(long delay,
java.util.concurrent.TimeUnit unit,
io.reactivex.Scheduler scheduler) |
Nono |
delaySubscription(org.reactivestreams.Publisher<?> other) |
Nono |
doAfterTerminate(io.reactivex.functions.Action onTerminate)
Executes the callback after this Nono terminates and the downstream
is notified.
|
Nono |
doFinally(io.reactivex.functions.Action onFinally)
Executes the callback exactly if the upstream terminates or
the downstream cancels the sequence.
|
Nono |
doOnCancel(io.reactivex.functions.Action onCancel)
Executes the callback if the downstream cancels the sequence.
|
Nono |
doOnComplete(io.reactivex.functions.Action onComplete) |
Nono |
doOnError(io.reactivex.functions.Consumer<? super java.lang.Throwable> onError) |
Nono |
doOnRequest(io.reactivex.functions.LongConsumer onRequest) |
Nono |
doOnSubscribe(io.reactivex.functions.Consumer<? super org.reactivestreams.Subscription> onSubscribe) |
static Nono |
error(java.util.concurrent.Callable<? extends java.lang.Throwable> errorSupplier)
Returns a Nono that signals a Throwable generated by the
callable for each individual subscriber.
|
static Nono |
error(java.lang.Throwable ex)
Returns a Nono that signals the given Throwable to all
subscribers.
|
<T> io.reactivex.Flowable<T> |
flatMap(io.reactivex.functions.Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends T>> onErrorMapper,
java.util.concurrent.Callable<? extends org.reactivestreams.Publisher<? extends T>> onCompleteMapper) |
static Nono |
fromAction(io.reactivex.functions.Action action)
Executes an action when a subscriber subscribes to the returned
Nono.
|
static Nono |
fromCompletable(io.reactivex.CompletableSource source)
Wrap a Completable into a Nono and terminate when the
source Completable terminates.
|
static Nono |
fromFuture(java.util.concurrent.Future<?> future)
Blockingly waits indefinitely for the given Future to terminate,
relaying any error the Future signals.
|
static Nono |
fromFuture(java.util.concurrent.Future<?> future,
long timeout,
java.util.concurrent.TimeUnit unit)
Blockingly waits the given Future for the given timeout to terminate,
relaying any error the Future signals.
|
static Nono |
fromMaybe(io.reactivex.MaybeSource<?> source)
Wrap a Maybe, ignore its success value and terminate if
the source Maybe terminates.
|
static Nono |
fromObservable(io.reactivex.ObservableSource<?> source)
Wrap a general Observable, ignore all of its values and terminate if
the source Observable terminates.
|
static Nono |
fromPublisher(org.reactivestreams.Publisher<?> source)
Wrap a general Publisher, ignore all of its values and terminate if
the source Publisher terminates.
|
static Nono |
fromSingle(io.reactivex.SingleSource<?> source)
Wrap a Single, ignore its success value and terminate if
the source Single terminates.
|
static io.reactivex.functions.Function<Nono,Nono> |
getOnAssemblyHandler()
Returns the current onAssembly handler function or null if not set.
|
Nono |
hide()
Hides the identity of this Nono.
|
Nono |
lift(io.reactivex.functions.Function<org.reactivestreams.Subscriber<? super java.lang.Void>,org.reactivestreams.Subscriber<? super java.lang.Void>> lifter)
Transform the downstream's Subscriber into a Subscriber for the upstream
via a function.
|
Nono |
mapError(io.reactivex.functions.Function<? super java.lang.Throwable,? extends java.lang.Throwable> mapper) |
static Nono |
merge(java.lang.Iterable<? extends Nono> sources)
Runs all Nono sources at once and completes once all of them complete.
|
static Nono |
merge(java.lang.Iterable<? extends Nono> sources,
int maxConcurrency)
Runs the maximum number of Nono sources at once and completes when all source
Nono complete.
|
static Nono |
merge(org.reactivestreams.Publisher<? extends Nono> sources)
Runs all Nono sources emitted by the Publisher at once and completes once all of them complete.
|
static Nono |
merge(org.reactivestreams.Publisher<? extends Nono> sources,
int maxConcurrency)
Runs the maximum number of Nono sources emitted by the Publisher at once and completes when all source
Nono complete.
|
static Nono |
mergeArray(int maxConcurrency,
Nono... sources)
Runs the maximum number of Nono sources at once and completes when all source
Nono complete.
|
static Nono |
mergeArray(Nono... sources)
Runs all Nono sources at once and completes once all of them complete.
|
static Nono |
mergeArrayDelayError(int maxConcurrency,
Nono... sources)
Runs the maximum number of Nono sources at once and terminates when all source
Nono terminate, delaying errors in the process.
|
static Nono |
mergeArrayDelayError(Nono... sources)
Runs all Nono sources at once and terminates once all
of them terminate, delaying errors in the process.
|
static Nono |
mergeDelayError(java.lang.Iterable<? extends Nono> sources)
Runs all Nono sources at once and terminates once all of them terminate,
delaying errors in the process.
|
static Nono |
mergeDelayError(java.lang.Iterable<? extends Nono> sources,
int maxConcurrency)
Runs the maximum number of Nono sources at once and terminates when all source
Nono terminate, delaying errors in the process.
|
static Nono |
mergeDelayError(org.reactivestreams.Publisher<? extends Nono> sources)
Runs all Nono sources emitted by the Publisher at once and terminates
once all of them terminate, delaying errors in the process.
|
static Nono |
mergeDelayError(org.reactivestreams.Publisher<? extends Nono> sources,
int maxConcurrency)
Runs the maximum number of Nono sources emitted by the Publisher
at once and terminates when all source Nono terminate,
delaying errors in the process.
|
static Nono |
never()
Returns a Nono that never terminates.
|
Nono |
observeOn(io.reactivex.Scheduler scheduler) |
protected static Nono |
onAssembly(Nono source)
Optionally apply a function to the raw source and return a
potentially modified Nono instance.
|
Nono |
onErrorComplete() |
Nono |
onErrorResumeNext(io.reactivex.functions.Function<? super java.lang.Throwable,? extends Nono> errorHandler) |
Nono |
repeat()
Repeatedly run this Nono indefinitely.
|
Nono |
repeat(io.reactivex.functions.BooleanSupplier stop)
Repeat until the given BooleanSupplier returns true.
|
Nono |
repeat(long times)
Repeatedly run this Nono at most the given number of times.
|
Nono |
repeatWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler)
Repeat when the Publisher returned by the handler function signals
a value or terminate accordingly.
|
Nono |
retry()
Repeatedly run this Nono indefinitely if it fails.
|
Nono |
retry(long times)
Repeatedly run this Nono at most the given number of times if it fails.
|
Nono |
retry(io.reactivex.functions.Predicate<? super java.lang.Throwable> predicate)
Retry a failed Nono if the predicate return true
|
Nono |
retryWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
Retry this Nono when the Publisher returned by the handler function
signals a normal item or terminate if the Publisher terminates.
|
static void |
setOnAssemblyHandler(io.reactivex.functions.Function<Nono,Nono> handler)
Sets the onAssembly handler.
|
io.reactivex.disposables.Disposable |
subscribe(io.reactivex.functions.Action onComplete)
Subscribe to this Nono and execute the given action if this Nono
completes.
|
io.reactivex.disposables.Disposable |
subscribe(io.reactivex.functions.Action onComplete,
io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)
Subscribe to this Nono and execute the given action if this Nono
completes or call the consumer if this Nono terminates with an error.
|
void |
subscribe(org.reactivestreams.Subscriber<? super java.lang.Void> s) |
protected abstract void |
subscribeActual(org.reactivestreams.Subscriber<? super java.lang.Void> s)
Implement this method to signal the terminal events to the given subscriber.
|
Nono |
subscribeOn(io.reactivex.Scheduler scheduler) |
<T,E extends org.reactivestreams.Subscriber<T>> |
subscribeWith(E subscriber)
Subscribe with the given subscriber and return the same subscriber, allowing
chaining methods on it or fluently reusing the instance.
|
Nono |
takeUntil(org.reactivestreams.Publisher<?> other)
Run this Nono and cancel it when the other Publisher signals
an item or completes.
|
io.reactivex.subscribers.TestSubscriber<java.lang.Void> |
test()
Create a TestSubscriber, subscribe it to this Nono and return
the TestSubscriber itself.
|
io.reactivex.subscribers.TestSubscriber<java.lang.Void> |
test(boolean cancelled)
Create a TestSubscriber, optionally cancel it, subscribe it to this Nono and return
the TestSubscriber itself.
|
Nono |
timeout(long delay,
java.util.concurrent.TimeUnit unit) |
Nono |
timeout(long delay,
java.util.concurrent.TimeUnit unit,
Nono fallback) |
Nono |
timeout(long delay,
java.util.concurrent.TimeUnit unit,
io.reactivex.Scheduler scheduler) |
Nono |
timeout(long delay,
java.util.concurrent.TimeUnit unit,
io.reactivex.Scheduler scheduler,
Nono fallback) |
Nono |
timeout(org.reactivestreams.Publisher<?> other) |
Nono |
timeout(org.reactivestreams.Publisher<?> other,
Nono fallback) |
static Nono |
timer(long delay,
java.util.concurrent.TimeUnit unit)
Completes after the specified amount of time on the computation scheduler.
|
static Nono |
timer(long delay,
java.util.concurrent.TimeUnit unit,
io.reactivex.Scheduler scheduler)
Completes after the specified amount of time on the specified scheduler.
|
<R> R |
to(io.reactivex.functions.Function<? super Nono,R> converter)
Fluently convert this Nono via a function callback into some type.
|
io.reactivex.Completable |
toCompletable() |
<T> io.reactivex.Flowable<T> |
toFlowable() |
<T> io.reactivex.Maybe<T> |
toMaybe() |
<T> io.reactivex.Observable<T> |
toObservable() |
Nono |
unsubscribeOn(io.reactivex.Scheduler scheduler) |
static <R> Nono |
using(java.util.concurrent.Callable<R> resourceSupplier,
io.reactivex.functions.Function<? super R,? extends Nono> sourceSupplier,
io.reactivex.functions.Consumer<? super R> disposer)
Generate a resource and a Nono based on that resource and then
dispose that resource eagerly when the Nono terminates or the
downstream cancels the sequence.
|
static <R> Nono |
using(java.util.concurrent.Callable<R> resourceSupplier,
io.reactivex.functions.Function<? super R,? extends Nono> sourceSupplier,
io.reactivex.functions.Consumer<? super R> disposer,
boolean eager)
Generate a resource and a Nono based on that resource and then
dispose that resource optionally eagerly when the Nono terminates or the
downstream cancels the sequence.
|
public static int bufferSize()
protected static Nono onAssembly(Nono source)
source - the source to apply topublic static io.reactivex.functions.Function<Nono,Nono> getOnAssemblyHandler()
public static void setOnAssemblyHandler(io.reactivex.functions.Function<Nono,Nono> handler)
handler - the new onAssembly handler, null clears the handlerpublic static Nono complete()
public static Nono never()
public static Nono error(java.lang.Throwable ex)
ex - the Throwable to signal, not nullpublic static Nono error(java.util.concurrent.Callable<? extends java.lang.Throwable> errorSupplier)
errorSupplier - the Throwable error supplier, not nullpublic static Nono defer(java.util.concurrent.Callable<? extends Nono> supplier)
supplier - the supplier of Nono instances for each individual
subscriber.public static Nono fromAction(io.reactivex.functions.Action action)
action - the action to execute, not nullpublic static Nono fromFuture(java.util.concurrent.Future<?> future)
future - the future to awaitpublic static Nono fromFuture(java.util.concurrent.Future<?> future, long timeout, java.util.concurrent.TimeUnit unit)
future - the future to awaittimeout - the timeout value to wait for terminationunit - the unit for the timeout parameterpublic static Nono amb(java.lang.Iterable<? extends Nono> sources)
sources - the Iterable sequence of sourcespublic static Nono ambArray(Nono... sources)
sources - the array of sourcespublic static Nono concat(java.lang.Iterable<? extends Nono> sources)
sources - the Iterable sequence of sourcespublic static Nono concat(org.reactivestreams.Publisher<? extends Nono> sources)
sources - the Publisher of Nono sourcespublic static Nono concat(org.reactivestreams.Publisher<? extends Nono> sources, int prefetch)
sources - the Publisher of Nono sourcesprefetch - the number of Nono sources to prefetch from upstreampublic static Nono concatArray(Nono... sources)
sources - the array of sourcespublic static Nono concatDelayError(java.lang.Iterable<? extends Nono> sources)
sources - the Iterable sequence of sourcespublic static Nono concatDelayError(org.reactivestreams.Publisher<? extends Nono> sources)
sources - the Publisher of source Nonospublic static Nono concatDelayError(org.reactivestreams.Publisher<? extends Nono> sources, int prefetch, boolean tillTheEnd)
sources - the Publisher of source Nonosprefetch - the number of Nonos to prefetch from the upstreamtillTheEnd - if true the errors from the source are also delayed till the end;
if false, error(s) are emitted when an inner Nono source terminatespublic static Nono concatArrayDelayError(Nono... sources)
sources - the array of sourcespublic static Nono merge(java.lang.Iterable<? extends Nono> sources)
sources - the Iterable sequence of Nono sourcespublic static Nono merge(java.lang.Iterable<? extends Nono> sources, int maxConcurrency)
sources - the Iterable sequence of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given timepublic static Nono merge(org.reactivestreams.Publisher<? extends Nono> sources)
sources - the Publisher of Nono sourcespublic static Nono merge(org.reactivestreams.Publisher<? extends Nono> sources, int maxConcurrency)
sources - the Publisher of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given timepublic static Nono mergeArray(Nono... sources)
sources - the array of Nono sourcespublic static Nono mergeArray(int maxConcurrency, Nono... sources)
sources - the array of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given timepublic static Nono mergeDelayError(java.lang.Iterable<? extends Nono> sources)
sources - the Iterable sequence of Nono sourcespublic static Nono mergeDelayError(java.lang.Iterable<? extends Nono> sources, int maxConcurrency)
sources - the Iterable sequence of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given timepublic static Nono mergeDelayError(org.reactivestreams.Publisher<? extends Nono> sources)
sources - the Publisher of Nono sourcespublic static Nono mergeDelayError(org.reactivestreams.Publisher<? extends Nono> sources, int maxConcurrency)
sources - the Publisher of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given timepublic static Nono mergeArrayDelayError(Nono... sources)
sources - the array of Nono sourcespublic static Nono mergeArrayDelayError(int maxConcurrency, Nono... sources)
sources - the array of Nono sourcesmaxConcurrency - the maximum number of active Nono sources at a given time@SchedulerSupport(value="io.reactivex:computation") public static Nono timer(long delay, java.util.concurrent.TimeUnit unit)
delay - the delay valueunit - the delay time unit@SchedulerSupport(value="custom") public static Nono timer(long delay, java.util.concurrent.TimeUnit unit, io.reactivex.Scheduler scheduler)
delay - the delay valueunit - the delay time unitscheduler - the scheduler to delay the completion signalpublic static <R> Nono using(java.util.concurrent.Callable<R> resourceSupplier, io.reactivex.functions.Function<? super R,? extends Nono> sourceSupplier, io.reactivex.functions.Consumer<? super R> disposer)
R - the resource typeresourceSupplier - the callback to get a resource for each subscribersourceSupplier - the function that returns a Nono for the generated resourcedisposer - the consumer of the resource once the upstream terminates or the
downstream cancelspublic static <R> Nono using(java.util.concurrent.Callable<R> resourceSupplier, io.reactivex.functions.Function<? super R,? extends Nono> sourceSupplier, io.reactivex.functions.Consumer<? super R> disposer, boolean eager)
R - the resource typeresourceSupplier - the callback to get a resource for each subscribersourceSupplier - the function that returns a Nono for the generated resourcedisposer - the consumer of the resource once the upstream terminates or the
downstream cancelseager - if true, the resource is disposed before the terminal event is emitted
if false, the resource is disposed after the terminal event has been emittedpublic static Nono fromPublisher(org.reactivestreams.Publisher<?> source)
source - the Publisher to wrap into a Nonopublic static Nono fromSingle(io.reactivex.SingleSource<?> source)
source - the SingleSource to wrap into a Nonopublic static Nono fromMaybe(io.reactivex.MaybeSource<?> source)
source - the MaybeSource to wrap into a Nonopublic static Nono fromCompletable(io.reactivex.CompletableSource source)
source - the MaybeSource to wrap into a Nonopublic static Nono fromObservable(io.reactivex.ObservableSource<?> source)
source - the ObservableSource to wrap into a Nonopublic final <T> io.reactivex.Flowable<T> andThen(org.reactivestreams.Publisher<? extends T> other)
@SchedulerSupport(value="io.reactivex:computation") public final Nono delay(long delay, java.util.concurrent.TimeUnit unit)
@SchedulerSupport(value="custom") public final Nono delay(long delay, java.util.concurrent.TimeUnit unit, io.reactivex.Scheduler scheduler)
public final Nono delaySubscription(org.reactivestreams.Publisher<?> other)
public final Nono delaySubscription(long delay, java.util.concurrent.TimeUnit unit)
public final Nono delaySubscription(long delay, java.util.concurrent.TimeUnit unit, io.reactivex.Scheduler scheduler)
public final Nono timeout(long delay, java.util.concurrent.TimeUnit unit)
public final Nono timeout(long delay, java.util.concurrent.TimeUnit unit, io.reactivex.Scheduler scheduler)
public final Nono timeout(long delay, java.util.concurrent.TimeUnit unit, io.reactivex.Scheduler scheduler, Nono fallback)
public final Nono timeout(org.reactivestreams.Publisher<?> other)
public final Nono onErrorComplete()
public final Nono onErrorResumeNext(io.reactivex.functions.Function<? super java.lang.Throwable,? extends Nono> errorHandler)
public final Nono mapError(io.reactivex.functions.Function<? super java.lang.Throwable,? extends java.lang.Throwable> mapper)
public final <T> io.reactivex.Flowable<T> flatMap(io.reactivex.functions.Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends T>> onErrorMapper,
java.util.concurrent.Callable<? extends org.reactivestreams.Publisher<? extends T>> onCompleteMapper)
public final Nono compose(io.reactivex.functions.Function<? super Nono,? extends Nono> composer)
composer - the function receiving this and returns a Nonopublic final <R> R to(io.reactivex.functions.Function<? super Nono,R> converter)
R - the result value typeconverter - the function receiving this and returning a valuepublic final Nono lift(io.reactivex.functions.Function<org.reactivestreams.Subscriber<? super java.lang.Void>,org.reactivestreams.Subscriber<? super java.lang.Void>> lifter)
lifter - the function receiving the downstream Subscriber and returns a Subscriber
for the upstream.public final <T> io.reactivex.Flowable<T> toFlowable()
public final <T> io.reactivex.Observable<T> toObservable()
public final io.reactivex.Completable toCompletable()
public final <T> io.reactivex.Maybe<T> toMaybe()
public final Nono subscribeOn(io.reactivex.Scheduler scheduler)
public final Nono observeOn(io.reactivex.Scheduler scheduler)
public final Nono unsubscribeOn(io.reactivex.Scheduler scheduler)
public final Nono doOnComplete(io.reactivex.functions.Action onComplete)
public final Nono doOnError(io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)
public final Nono doOnSubscribe(io.reactivex.functions.Consumer<? super org.reactivestreams.Subscription> onSubscribe)
public final Nono doOnRequest(io.reactivex.functions.LongConsumer onRequest)
public final Nono doAfterTerminate(io.reactivex.functions.Action onTerminate)
onTerminate - the callback to call after the downstream is notifiedpublic final Nono doFinally(io.reactivex.functions.Action onFinally)
onFinally - the action to callpublic final Nono doOnCancel(io.reactivex.functions.Action onCancel)
onCancel - the action to callpublic final Nono repeat()
public final Nono repeat(long times)
times - the repeat countpublic final Nono repeat(io.reactivex.functions.BooleanSupplier stop)
stop - the boolean supplier to return null to stop repeatingpublic final Nono repeatWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler)
handler - the Function that receives a Flowable that emits an object
when this Nono completes normally and should return a Publisher that if
signals a normal item, it triggers a resubscription to this Nono.public final Nono retry()
public final Nono retry(long times)
times - the repeat countpublic final Nono retry(io.reactivex.functions.Predicate<? super java.lang.Throwable> predicate)
predicate - the predicate receiving the failure Throwable and
returns true to trigger a retry.public final Nono retryWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
handler - the Function that receives a Flowable of the failure Throwable
and returns a Publisher that if signals a normal item, it triggers a
resubscription.public final Nono hide()
This also breaks optimizations such as operator fusion - useful when diagnosing issues.
public final Nono takeUntil(org.reactivestreams.Publisher<?> other)
other - the other Publisherpublic final void subscribe(org.reactivestreams.Subscriber<? super java.lang.Void> s)
subscribe in interface org.reactivestreams.Publisher<java.lang.Void>protected abstract void subscribeActual(org.reactivestreams.Subscriber<? super java.lang.Void> s)
s - the downstream subscriber, not null@SchedulerSupport(value="none") public final <T,E extends org.reactivestreams.Subscriber<T>> E subscribeWith(E subscriber)
T - the target value type of the subscriberE - the subscriber's (sub)typesubscriber - the subscriber to subscribe with, not null@SchedulerSupport(value="none") public final io.reactivex.subscribers.TestSubscriber<java.lang.Void> test()
@SchedulerSupport(value="none") public final io.reactivex.subscribers.TestSubscriber<java.lang.Void> test(boolean cancelled)
cancelled - shoud the TestSubscriber be cancelled before the subscription@SchedulerSupport(value="none") public final java.lang.Throwable blockingAwait()
@SchedulerSupport(value="none")
public final java.lang.Throwable blockingAwait(long timeout,
java.util.concurrent.TimeUnit unit)
timeout - the timeout valueunit - the time unit@SchedulerSupport(value="none") public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Action onComplete)
onComplete - the callback Action to be called when this Nono
completes@SchedulerSupport(value="none")
public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Action onComplete,
io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)
onComplete - the callback Action to be called when this Nono
completesonError - the callback Consumer to be called with the terminal
error.public final void blockingSubscribe(io.reactivex.functions.Action onComplete)
onComplete - the Action to call when this Nono terminatespublic final void blockingSubscribe(io.reactivex.functions.Action onComplete,
io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)
onComplete - the Action to call when this Nono completesonError - the Consumer to call when this Nono terminates with an error