eu.toolchain.concurrent

Class RetryCallHelper<T>

java.lang.Object

eu.toolchain.concurrent.RetryCallHelper<T>

Type Parameters:

T - result type of the retried operation

All Implemented Interfaces:

Handle<T>

public class RetryCallHelper<T>
extends Object
implements Handle<T>

A helper class for retry-until-completed behaviour.

retry-until-completed is provided by Async.retryUntilCompleted(java.util.concurrent.Callable, RetryPolicy).

Constructor Summary

Constructors

Constructor and Description
RetryCallHelper(long start, ScheduledExecutorService scheduler, Callable<? extends Stage<? extends T>> callable, Supplier<RetryDecision> policyInstance, Completable<T> future, ClockSource clockSource)

Method Summary

Modifier and Type	Method and Description
void	cancelled() Handle to be called when the underlying stage is cancelled.
void	completed(T result) Handle to be called when the underlying stage is completed.
void	failed(Throwable cause) Handle to be called when the underlying stage is failed.
void	finished() Must be called when the target completable finishes to clean up any potential scheduled _future_ events.
List<RetryException>	getErrors()
void	next()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryCallHelper

public RetryCallHelper(long start,
                       ScheduledExecutorService scheduler,
                       Callable<? extends Stage<? extends T>> callable,
                       Supplier<RetryDecision> policyInstance,
                       Completable<T> future,
                       ClockSource clockSource)

Method Detail

getErrors

public List<RetryException> getErrors()

failed

public void failed(Throwable cause)

Description copied from interface: Handle

Handle to be called when the underlying stage is failed.

Specified by:

failed in interface Handle<T>

Parameters:

cause - exception that caused the underlying stage to fail

completed

public void completed(T result)

Description copied from interface: Handle

Handle to be called when the underlying stage is completed.

Specified by:

completed in interface Handle<T>

Parameters:

result - The result of the completed stage.

cancelled

public void cancelled()

Description copied from interface: Handle

Handle to be called when the underlying stage is cancelled.

Specified by:

cancelled in interface Handle<T>

next

public void next()

finished

public void finished()

Must be called when the target completable finishes to clean up any potential scheduled _future_ events.