Modifier and Type | Field and Description |
---|---|
static ClockSource |
ClockSource.SYSTEM |
Modifier and Type | Method and Description |
---|---|
static ClockSource |
ClockSource.system() |
Modifier and Type | Method and Description |
---|---|
CoreAsync.Builder |
CoreAsync.Builder.clockSource(ClockSource clockSource)
Configure clock source.
|
Supplier<RetryDecision> |
RetryPolicy.newInstance(ClockSource clockSource)
Create a new instance of the policy.
|
Supplier<RetryDecision> |
RetryPolicy.Timed.newInstance(ClockSource clockSource) |
Supplier<RetryDecision> |
RetryPolicy.Linear.newInstance(ClockSource clockSource) |
Supplier<RetryDecision> |
RetryPolicy.Exponential.newInstance(ClockSource clockSource) |
<T> Stage<RetryResult<T>> |
CoreAsync.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy,
ClockSource clockSource) |
<T> Stage<RetryResult<T>> |
Async.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy,
ClockSource clockSource)
Retry the given action until it has been completed, or the provided
RetryPolicy expire. |
Constructor and Description |
---|
RetryCallHelper(long start,
ScheduledExecutorService scheduler,
Callable<? extends Stage<? extends T>> callable,
Supplier<RetryDecision> policyInstance,
Completable<T> future,
ClockSource clockSource) |
Copyright © 2017. All rights reserved.