A B C D E F G H I J L M N P R S T U W

A

Async - Interface in eu.toolchain.concurrent

The async framework.

B

backoff() - Method in class eu.toolchain.concurrent.RetryDecision

How many milliseconds should the retry wait for until it can be retried.

borrow() - Method in class eu.toolchain.concurrent.ConcurrentManaged

borrow() - Method in interface eu.toolchain.concurrent.Managed

Borrow the underlying reference.

Borrowed<T> - Interface in eu.toolchain.concurrent

A borrowed reference.

build() - Method in class eu.toolchain.concurrent.CoreAsync.Builder

build() - Method in class eu.toolchain.concurrent.ManagedOptions.Builder

build() - Method in class eu.toolchain.concurrent.RetryPolicy.ExponentialBuilder

builder() - Static method in class eu.toolchain.concurrent.CoreAsync

Build a new CoreAsync instance.

builder() - Static method in class eu.toolchain.concurrent.ManagedOptions

C

call(Callable<? extends T>) - Method in interface eu.toolchain.concurrent.Async

Call the given callable on the default executor and track the result using a completable.

call(Callable<? extends T>, ExecutorService) - Method in interface eu.toolchain.concurrent.Async

Call the given callable on the provided executor and track the result using a completable.

call(Callable<? extends C>) - Method in class eu.toolchain.concurrent.CoreAsync

call(Callable<? extends C>, ExecutorService) - Method in class eu.toolchain.concurrent.CoreAsync

Caller - Interface in eu.toolchain.concurrent

Methods for calling user-defined actions and report errors.

caller(Caller) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Specify an asynchronous caller implementation.

caller() - Method in class eu.toolchain.concurrent.CoreAsync

callerExecutor(ExecutorService) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Specify a separate executor to use for caller (internal handle) invocation.

cancel() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

cancel() - Method in class eu.toolchain.concurrent.ImmediateCancelled

cancel() - Method in class eu.toolchain.concurrent.ImmediateCompleted

cancel() - Method in class eu.toolchain.concurrent.ImmediateFailed

cancel() - Method in interface eu.toolchain.concurrent.Stage

Cancel the current stage.

cancelled() - Method in interface eu.toolchain.concurrent.Async

Build an immediately cancelled completable.

cancelled() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

cancelled() - Method in class eu.toolchain.concurrent.CoreAsync

cancelled() - Method in class eu.toolchain.concurrent.DelayedCollectCoordinator

cancelled() - Method in interface eu.toolchain.concurrent.Handle

Handle to be called when the underlying stage is cancelled.

cancelled() - Method in class eu.toolchain.concurrent.RetryCallHelper

CANCELLED - Static variable in interface eu.toolchain.concurrent.Stage

CAPTURE_STACK - Static variable in interface eu.toolchain.concurrent.Managed

System property that if set to 'yes', will cause stacks to be captured by borrowed references.

captureStack(boolean) - Method in class eu.toolchain.concurrent.ManagedOptions.Builder

Configure if managed references should capture stack traces when borrowed.

cause() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

cause() - Method in class eu.toolchain.concurrent.ImmediateCancelled

cause() - Method in class eu.toolchain.concurrent.ImmediateCompleted

cause() - Method in class eu.toolchain.concurrent.ImmediateFailed

cause() - Method in interface eu.toolchain.concurrent.Stage

Get the cause of a failed stage.

ClockSource - Interface in eu.toolchain.concurrent

A clock source that gives the current time in milliseconds.

clockSource(ClockSource) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Configure clock source.

close() - Method in interface eu.toolchain.concurrent.Borrowed

The close method, as defined by AutoCloseable.close() to allow for try-with-resources statements.

collect(Stream<? extends Stage<T>>) - Method in interface eu.toolchain.concurrent.Async

Collect the result of multiple stages from a stream.

collect(Collection<? extends Stage<? extends T>>) - Method in interface eu.toolchain.concurrent.Async

Build a new completable that is the result of collecting all the results in a collection.

collect(Collection<? extends Stage<? extends T>>, Function<? super Collection<T>, ? extends U>) - Method in interface eu.toolchain.concurrent.Async

Build a new completable that is the result of reducing the provided collection of stages using the provided collector.

collect(Collection<? extends Stage<? extends T>>) - Method in class eu.toolchain.concurrent.CoreAsync

collect(Collection<? extends Stage<? extends C>>, Function<? super Collection<C>, ? extends T>) - Method in class eu.toolchain.concurrent.CoreAsync

collectAndDiscard(Stream<? extends Stage<?>>) - Method in interface eu.toolchain.concurrent.Async

Collect the results from a stream of stages, then discard them.

collectAndDiscard(Collection<? extends Stage<?>>) - Method in interface eu.toolchain.concurrent.Async

Collect the results from a collection of stages, then discard them.

collectAndDiscard(Collection<? extends Stage<?>>) - Method in class eu.toolchain.concurrent.CoreAsync

completable() - Method in interface eu.toolchain.concurrent.Async

Build a new resolvable completable.

Completable<T> - Interface in eu.toolchain.concurrent

A value that can be completed at a later point in time.

completable() - Method in class eu.toolchain.concurrent.CoreAsync

complete(T) - Method in interface eu.toolchain.concurrent.Completable

Complete the current stage.

complete(T) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

completed() - Method in interface eu.toolchain.concurrent.Async

Returns an already completed void completable.

completed(T) - Method in interface eu.toolchain.concurrent.Async

Build an already completed completable.

completed(T) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

completed() - Method in class eu.toolchain.concurrent.CoreAsync

completed(T) - Method in class eu.toolchain.concurrent.CoreAsync

completed(S) - Method in class eu.toolchain.concurrent.DelayedCollectCoordinator

completed(T) - Method in interface eu.toolchain.concurrent.Handle

Handle to be called when the underlying stage is completed.

completed(T) - Method in class eu.toolchain.concurrent.RetryCallHelper

COMPLETED - Static variable in interface eu.toolchain.concurrent.Stage

ConcurrentCompletable<T> - Class in eu.toolchain.concurrent

A concurrent implementation of Completable.

ConcurrentCompletable(Caller) - Constructor for class eu.toolchain.concurrent.ConcurrentCompletable

Setup a concurrent completable that uses a custom caller implementation.

ConcurrentManaged<T> - Class in eu.toolchain.concurrent

A thread-safe implementation of Managed.

CoreAsync - Class in eu.toolchain.concurrent

Entry point to the tiny async framework.

CoreAsync() - Constructor for class eu.toolchain.concurrent.CoreAsync

CoreAsync.Builder - Class in eu.toolchain.concurrent

Builder for CoreAsync.

CTX - Static variable in class eu.toolchain.concurrent.PrintStreamCaller

D

DelayedCollectCoordinator<S,T> - Class in eu.toolchain.concurrent

Coordinator thread for handling delayed callables executing with a given parallelism.

DelayedCollectCoordinator(Caller, Collection<? extends Callable<? extends Stage<? extends S>>>, Consumer<S>, Supplier<T>, Completable<? super T>, int) - Constructor for class eu.toolchain.concurrent.DelayedCollectCoordinator

DirectCaller - Class in eu.toolchain.concurrent

An abstract implementation of a caller that invokes the handles directly in the calling thread.

DirectCaller() - Constructor for class eu.toolchain.concurrent.DirectCaller

doCall(Callable<? extends C>, ExecutorService, Completable<C>) - Method in class eu.toolchain.concurrent.CoreAsync

doCollect(Collection<? extends Stage<? extends C>>, Function<? super Collection<C>, ? extends T>) - Method in class eu.toolchain.concurrent.CoreAsync

doto(Function<? super T, ? extends Stage<R>>) - Method in class eu.toolchain.concurrent.ConcurrentManaged

doto(Function<? super T, ? extends Stage<U>>) - Method in interface eu.toolchain.concurrent.Managed

Borrow a reference and execute the given action.

E

eu.toolchain.concurrent - package eu.toolchain.concurrent

Replacement classes for asynchronous operations in Java.

eventuallyCollect(Collection<? extends Callable<? extends Stage<? extends T>>>, Consumer<? super T>, Supplier<? extends U>, int) - Method in interface eu.toolchain.concurrent.Async

Collect the result from a collection of operations that are lazily created.

eventuallyCollect(Collection<? extends Callable<? extends Stage<? extends C>>>, Consumer<? super C>, Supplier<? extends T>, int) - Method in class eu.toolchain.concurrent.CoreAsync

execute(Runnable) - Method in interface eu.toolchain.concurrent.Caller

Execute the given action.

execute(Runnable) - Method in class eu.toolchain.concurrent.DirectCaller

execute(Runnable) - Method in class eu.toolchain.concurrent.ExecutorCaller

execute(Runnable) - Method in class eu.toolchain.concurrent.RecursionSafeCaller

executor(ExecutorService) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Configure the default executor to use for caller invocation,and asynchronous tasks submitted through Async.call(Callable).

executor() - Method in class eu.toolchain.concurrent.CoreAsync

Fetch the configured primary executor (if any).

ExecutorCaller - Class in eu.toolchain.concurrent

A Caller implementation that defers all execution to a ExecutorService.

ExecutorCaller() - Constructor for class eu.toolchain.concurrent.ExecutorCaller

exponential(long, TimeUnit) - Static method in interface eu.toolchain.concurrent.RetryPolicy

Setup an exponential backoff retry policy.

F

factor(double) - Method in class eu.toolchain.concurrent.RetryPolicy.ExponentialBuilder

Factor to use when increasing the retry delay.

fail(Throwable) - Method in interface eu.toolchain.concurrent.Completable

Fail the current stage.

fail(Throwable) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

failed(Throwable) - Method in interface eu.toolchain.concurrent.Async

Build an already failed completable.

failed(Throwable) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

failed(Throwable) - Method in class eu.toolchain.concurrent.CoreAsync

failed(Throwable) - Method in class eu.toolchain.concurrent.DelayedCollectCoordinator

failed(Throwable) - Method in interface eu.toolchain.concurrent.Handle

Handle to be called when the underlying stage is failed.

failed(Throwable) - Method in class eu.toolchain.concurrent.RetryCallHelper

FAILED - Static variable in interface eu.toolchain.concurrent.Stage

finished() - Method in class eu.toolchain.concurrent.RetryCallHelper

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

G

get() - Method in interface eu.toolchain.concurrent.Borrowed

Fetch the borrowed reference.

getErrors() - Method in class eu.toolchain.concurrent.RetryCallHelper

getErrors() - Method in class eu.toolchain.concurrent.RetryResult

getOffsetMillis() - Method in exception eu.toolchain.concurrent.RetryException

Offset from start time in milliseconds that this failure happened.

getResult() - Method in class eu.toolchain.concurrent.RetryResult

H

handle(Handle<? super T>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

Handle<T> - Interface in eu.toolchain.concurrent

Handle to implement that can catch all the different states of a stage.

handle(Handle<? super T>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

handle(Handle<? super T>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

handle(Handle<? super T>) - Method in class eu.toolchain.concurrent.ImmediateFailed

handle(Handle<? super T>) - Method in interface eu.toolchain.concurrent.Stage

Register a listener that is called on all three types of events for the current stage; completed, failed, and cancelled.

I

ImmediateCancelled<T> - Class in eu.toolchain.concurrent

A stage which has already been cancelled.

ImmediateCancelled(Caller) - Constructor for class eu.toolchain.concurrent.ImmediateCancelled

ImmediateCompleted<T> - Class in eu.toolchain.concurrent

A stage which has already been completed.

ImmediateCompleted(Caller, T) - Constructor for class eu.toolchain.concurrent.ImmediateCompleted

ImmediateFailed<T> - Class in eu.toolchain.concurrent

A stage which has already failed.

ImmediateFailed(Caller, Throwable) - Constructor for class eu.toolchain.concurrent.ImmediateFailed

internalError(String, Throwable) - Method in class eu.toolchain.concurrent.DirectCaller

internalError(String, Throwable) - Method in class eu.toolchain.concurrent.PrintStreamCaller

isCancelled() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

isCancelled() - Method in class eu.toolchain.concurrent.ImmediateCancelled

isCancelled() - Method in class eu.toolchain.concurrent.ImmediateCompleted

isCancelled() - Method in class eu.toolchain.concurrent.ImmediateFailed

isCancelled() - Method in interface eu.toolchain.concurrent.Stage

Check if stage is in the cancelled state.

isCompleted() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

isCompleted() - Method in class eu.toolchain.concurrent.ImmediateCancelled

isCompleted() - Method in class eu.toolchain.concurrent.ImmediateCompleted

isCompleted() - Method in class eu.toolchain.concurrent.ImmediateFailed

isCompleted() - Method in interface eu.toolchain.concurrent.Stage

Check if stage is completed.

isDone() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

isDone() - Method in class eu.toolchain.concurrent.ImmediateCancelled

isDone() - Method in class eu.toolchain.concurrent.ImmediateCompleted

isDone() - Method in class eu.toolchain.concurrent.ImmediateFailed

isDone() - Method in interface eu.toolchain.concurrent.Stage

Indicates if the stage is done

isFailed() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

isFailed() - Method in class eu.toolchain.concurrent.ImmediateCancelled

isFailed() - Method in class eu.toolchain.concurrent.ImmediateCompleted

isFailed() - Method in class eu.toolchain.concurrent.ImmediateFailed

isFailed() - Method in interface eu.toolchain.concurrent.Stage

Check if the stage was exceptionally completed.

isReady() - Method in class eu.toolchain.concurrent.ConcurrentManaged

isReady() - Method in interface eu.toolchain.concurrent.Managed

If managed reference is started, but not stopping or stopped.

isValid() - Method in interface eu.toolchain.concurrent.Borrowed

Check if the borrowed reference is valid.

J

join() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

join(long, TimeUnit) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

join() - Method in class eu.toolchain.concurrent.ImmediateCancelled

join(long, TimeUnit) - Method in class eu.toolchain.concurrent.ImmediateCancelled

join() - Method in class eu.toolchain.concurrent.ImmediateCompleted

join(long, TimeUnit) - Method in class eu.toolchain.concurrent.ImmediateCompleted

join() - Method in class eu.toolchain.concurrent.ImmediateFailed

join(long, TimeUnit) - Method in class eu.toolchain.concurrent.ImmediateFailed

join() - Method in interface eu.toolchain.concurrent.Stage

Join the result of the current stage.

join(long, TimeUnit) - Method in interface eu.toolchain.concurrent.Stage

Join the result of the current stage with a timeout.

joinNow() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

joinNow() - Method in class eu.toolchain.concurrent.ImmediateCancelled

joinNow() - Method in class eu.toolchain.concurrent.ImmediateCompleted

joinNow() - Method in class eu.toolchain.concurrent.ImmediateFailed

joinNow() - Method in interface eu.toolchain.concurrent.Stage

Join the result of the current stage, or fail if it's state is still running.

L

linear(long, TimeUnit) - Static method in interface eu.toolchain.concurrent.RetryPolicy

Build a linear retry policy.

M

managed(Supplier<? extends Stage<T>>, Function<? super T, ? extends Stage<Void>>) - Method in interface eu.toolchain.concurrent.Async

Setup a managed reference.

managed(Supplier<? extends Stage<C>>, Function<? super C, ? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.CoreAsync

Managed<T> - Interface in eu.toolchain.concurrent

Managed lightweight, reference-counted objects.

managedOptions(ManagedOptions) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

ManagedOptions - Class in eu.toolchain.concurrent

Options that can be modified when building Managed reference.

ManagedOptions() - Constructor for class eu.toolchain.concurrent.ManagedOptions

ManagedOptions.Builder - Class in eu.toolchain.concurrent

Options builder.

max(long, TimeUnit) - Method in class eu.toolchain.concurrent.RetryPolicy.ExponentialBuilder

Max possible delay.

maxRecursionDepth(long) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Configure how many recursions should be allowed.

N

newDefault() - Static method in class eu.toolchain.concurrent.ManagedOptions

newInstance(ClockSource) - Method in class eu.toolchain.concurrent.RetryPolicy.Exponential

newInstance(ClockSource) - Method in class eu.toolchain.concurrent.RetryPolicy.Linear

newInstance(ClockSource) - Method in interface eu.toolchain.concurrent.RetryPolicy

Create a new instance of the policy.

newInstance(ClockSource) - Method in class eu.toolchain.concurrent.RetryPolicy.Timed

newManaged(Async, Caller, ManagedOptions, Supplier<? extends Stage<T>>, Function<? super T, ? extends Stage<Void>>) - Static method in class eu.toolchain.concurrent.ConcurrentManaged

next() - Method in class eu.toolchain.concurrent.RetryCallHelper

now() - Method in interface eu.toolchain.concurrent.ClockSource

Get the current time in milliseconds.

P

PENDING - Static variable in interface eu.toolchain.concurrent.Stage

PrintStreamCaller - Class in eu.toolchain.concurrent

The simplest possible implementation of a concurrent caller.

PrintStreamCaller(PrintStream) - Constructor for class eu.toolchain.concurrent.PrintStreamCaller

R

recursionSafe(boolean) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Configure that all caller invocations should use a recursion safe mechanism.

RecursionSafeCaller - Class in eu.toolchain.concurrent

A Caller implementation that implements immediate calling, and provides a fallback to avoid blowing up the stack when operations are recursively called.

RecursionSafeCaller(ExecutorService, Caller, long) - Constructor for class eu.toolchain.concurrent.RecursionSafeCaller

RecursionSafeCaller(ExecutorService, Caller) - Constructor for class eu.toolchain.concurrent.RecursionSafeCaller

referenceLeaked(Object, StackTraceElement[]) - Method in interface eu.toolchain.concurrent.Caller

Indicate that a Managed reference has been leaked.

referenceLeaked(Object, StackTraceElement[]) - Method in class eu.toolchain.concurrent.DirectCaller

referenceLeaked(Object, StackTraceElement[]) - Method in class eu.toolchain.concurrent.ExecutorCaller

referenceLeaked(Object, StackTraceElement[]) - Method in class eu.toolchain.concurrent.RecursionSafeCaller

release() - Method in interface eu.toolchain.concurrent.Borrowed

Release the borrowed reference.

reload() - Method in interface eu.toolchain.concurrent.ReloadableManaged

Reload the underlying reference.

reloadableManaged(Supplier<? extends Stage<T>>, Function<? super T, ? extends Stage<Void>>) - Method in interface eu.toolchain.concurrent.Async

Setup a reloadable, managed reference.

reloadableManaged(Supplier<? extends Stage<C>>, Function<? super C, ? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.CoreAsync

ReloadableManaged<T> - Interface in eu.toolchain.concurrent

Managed lightweight, reference-counted objects that can be reloaded.

RetryCallHelper<T> - Class in eu.toolchain.concurrent

A helper class for retry-until-completed behaviour.

RetryCallHelper(long, ScheduledExecutorService, Callable<? extends Stage<? extends T>>, Supplier<RetryDecision>, Completable<T>, ClockSource) - Constructor for class eu.toolchain.concurrent.RetryCallHelper

RetryDecision - Class in eu.toolchain.concurrent

The decision of an applied retry policy.

RetryException - Exception in eu.toolchain.concurrent

An exception class containing detailed information about when a retried operation failed.

RetryException(long, Throwable) - Constructor for exception eu.toolchain.concurrent.RetryException

RetryPolicy - Interface in eu.toolchain.concurrent

A policy that governs how and when an operation should be retried.

RetryPolicy.Exponential - Class in eu.toolchain.concurrent

Implementation for the exponential retry policy.

RetryPolicy.ExponentialBuilder - Class in eu.toolchain.concurrent

Builder of exponential retry policies.

RetryPolicy.Linear - Class in eu.toolchain.concurrent

Implementation for the linear retry policy.

RetryPolicy.Timed - Class in eu.toolchain.concurrent

Implementation for the timed retry policy.

RetryResult<T> - Class in eu.toolchain.concurrent

Contains the result of a retry operation.

RetryResult(T, List<RetryException>) - Constructor for class eu.toolchain.concurrent.RetryResult

retryUntilCompleted(Callable<? extends Stage<T>>, RetryPolicy) - Method in interface eu.toolchain.concurrent.Async

Retry the given action until it has been completed, or the provided RetryPolicy expire.

retryUntilCompleted(Callable<? extends Stage<T>>, RetryPolicy, ClockSource) - Method in interface eu.toolchain.concurrent.Async

Retry the given action until it has been completed, or the provided RetryPolicy expire.

retryUntilCompleted(Callable<? extends Stage<T>>, RetryPolicy) - Method in class eu.toolchain.concurrent.CoreAsync

retryUntilCompleted(Callable<? extends Stage<T>>, RetryPolicy, ClockSource) - Method in class eu.toolchain.concurrent.CoreAsync

run() - Method in class eu.toolchain.concurrent.DelayedCollectCoordinator

S

scheduler(ScheduledExecutorService) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Specify a scheduler to use with the built CoreAsync instance.

shouldRetry() - Method in class eu.toolchain.concurrent.RetryDecision

If another retry should be attemped.

Stage<T> - Interface in eu.toolchain.concurrent

An interface that defines a contract with a computation that could be asynchronous.

start() - Method in class eu.toolchain.concurrent.ConcurrentManaged

start() - Method in interface eu.toolchain.concurrent.Managed

Start the managed reference.

stop() - Method in class eu.toolchain.concurrent.ConcurrentManaged

stop() - Method in interface eu.toolchain.concurrent.Managed

Stop the underlying managed reference.

streamCollect(Collection<? extends Stage<? extends T>>, Consumer<? super T>, Supplier<? extends U>) - Method in interface eu.toolchain.concurrent.Async

Build a new stage that is the result of applying a computation on a collection of stages.

streamCollect(Collection<? extends Stage<? extends T>>, Consumer<? super T>, Supplier<? extends U>) - Method in class eu.toolchain.concurrent.CoreAsync

SYSTEM - Static variable in interface eu.toolchain.concurrent.ClockSource

system() - Static method in interface eu.toolchain.concurrent.ClockSource

T

thenApply(Function<? super T, ? extends U>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenApply(Function<? super T, ? extends U>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenApply(Function<? super T, ? extends R>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenApply(Function<? super T, ? extends U>) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenApply(Function<? super T, ? extends U>) - Method in interface eu.toolchain.concurrent.Stage

Transform the value of the current stage into another type using an immediate function.

thenApplyFailed(Function<? super Throwable, ? extends T>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenApplyFailed(Function<? super Throwable, ? extends T>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenApplyFailed(Function<? super Throwable, ? extends T>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenApplyFailed(Function<? super Throwable, ? extends T>) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenApplyFailed(Function<? super Throwable, ? extends T>) - Method in interface eu.toolchain.concurrent.Stage

Apply a failed stage.

thenCancel() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenCancel() - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenCancel() - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenCancel() - Method in class eu.toolchain.concurrent.ImmediateFailed

thenCancel() - Method in interface eu.toolchain.concurrent.Stage

Build a stage is cancelled, but waits until the current stage completes.

thenComplete(U) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenComplete(U) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenComplete(U) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenComplete(U) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenComplete(U) - Method in interface eu.toolchain.concurrent.Stage

Build a stage is completed, but waits until the current stage completes.

thenCompose(Function<? super T, ? extends Stage<U>>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenCompose(Function<? super T, ? extends Stage<U>>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenCompose(Function<? super T, ? extends Stage<R>>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenCompose(Function<? super T, ? extends Stage<U>>) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenCompose(Function<? super T, ? extends Stage<U>>) - Method in interface eu.toolchain.concurrent.Stage

Compose the current stage with the given function.

thenComposeCaught(Function<? super Throwable, ? extends Stage<T>>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenComposeCaught(Function<? super Throwable, ? extends Stage<T>>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenComposeCaught(Function<? super Throwable, ? extends Stage<T>>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenComposeCaught(Function<? super Throwable, ? extends Stage<T>>) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenComposeCaught(Function<? super Throwable, ? extends Stage<T>>) - Method in interface eu.toolchain.concurrent.Stage

Compose a failed stage.

thenFail(Throwable) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

thenFail(Throwable) - Method in class eu.toolchain.concurrent.ImmediateCancelled

thenFail(Throwable) - Method in class eu.toolchain.concurrent.ImmediateCompleted

thenFail(Throwable) - Method in class eu.toolchain.concurrent.ImmediateFailed

thenFail(Throwable) - Method in interface eu.toolchain.concurrent.Stage

Build a stage is failed, but waits until the current stage completes.

threaded(boolean) - Method in class eu.toolchain.concurrent.CoreAsync.Builder

Configure that all caller invocation, and async tasks should be using a thread pool.

timed(long, TimeUnit, RetryPolicy) - Static method in interface eu.toolchain.concurrent.RetryPolicy

Wrap an existing retry policy which is only valid for a given time.

toString() - Method in class eu.toolchain.concurrent.ConcurrentCompletable

toString() - Method in class eu.toolchain.concurrent.ConcurrentManaged

toString() - Method in class eu.toolchain.concurrent.ImmediateCancelled

toString() - Method in class eu.toolchain.concurrent.ImmediateCompleted

toString() - Method in class eu.toolchain.concurrent.ImmediateFailed

toString() - Method in class eu.toolchain.concurrent.RetryDecision

toString() - Method in exception eu.toolchain.concurrent.RetryException

toString() - Method in class eu.toolchain.concurrent.RetryPolicy.Exponential

toString() - Method in class eu.toolchain.concurrent.RetryPolicy.Linear

toString() - Method in class eu.toolchain.concurrent.RetryPolicy.Timed

TRACING - Static variable in interface eu.toolchain.concurrent.Managed

System property that if set to 'yes', will cause the managed references to be traced.

tracing(boolean) - Method in class eu.toolchain.concurrent.ManagedOptions.Builder

Configure if managed references should trace all it's borrowed references.

U

UNIT - Static variable in interface eu.toolchain.concurrent.ClockSource

W

whenCancelled(Runnable) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

whenCancelled(Runnable) - Method in class eu.toolchain.concurrent.ImmediateCancelled

whenCancelled(Runnable) - Method in class eu.toolchain.concurrent.ImmediateCompleted

whenCancelled(Runnable) - Method in class eu.toolchain.concurrent.ImmediateFailed

whenCancelled(Runnable) - Method in interface eu.toolchain.concurrent.Stage

Register an listener to be called when the current stage is cancelled.

whenComplete(Consumer<? super T>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

whenComplete(Consumer<? super T>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

whenComplete(Consumer<? super T>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

whenComplete(Consumer<? super T>) - Method in class eu.toolchain.concurrent.ImmediateFailed

whenComplete(Consumer<? super T>) - Method in interface eu.toolchain.concurrent.Stage

Register a listener to be called when the current stage is completed.

whenDone(Runnable) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

whenDone(Runnable) - Method in class eu.toolchain.concurrent.ImmediateCancelled

whenDone(Runnable) - Method in class eu.toolchain.concurrent.ImmediateCompleted

whenDone(Runnable) - Method in class eu.toolchain.concurrent.ImmediateFailed

whenDone(Runnable) - Method in interface eu.toolchain.concurrent.Stage

Register a listener to be called when the current stage finishes for any reason.

whenFailed(Consumer<? super Throwable>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

whenFailed(Consumer<? super Throwable>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

whenFailed(Consumer<? super Throwable>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

whenFailed(Consumer<? super Throwable>) - Method in class eu.toolchain.concurrent.ImmediateFailed

whenFailed(Consumer<? super Throwable>) - Method in interface eu.toolchain.concurrent.Stage

Register a listener that is called when a stage is failed.

withCloser(Supplier<? extends Stage<Void>>, Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

withCloser(Supplier<? extends Stage<Void>>, Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

withCloser(Supplier<? extends Stage<Void>>, Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

withCloser(Supplier<? extends Stage<Void>>, Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateFailed

withCloser(Supplier<? extends Stage<Void>>, Supplier<? extends Stage<Void>>) - Method in interface eu.toolchain.concurrent.Stage

Run one of the provided stages when this stage ends up in a given state.

withComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

withComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

withComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

withComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateFailed

withComplete(Supplier<? extends Stage<Void>>) - Method in interface eu.toolchain.concurrent.Stage

Run the provided stage when the current stage has completed.

withNotComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ConcurrentCompletable

withNotComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCancelled

withNotComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateCompleted

withNotComplete(Supplier<? extends Stage<Void>>) - Method in class eu.toolchain.concurrent.ImmediateFailed

withNotComplete(Supplier<? extends Stage<Void>>) - Method in interface eu.toolchain.concurrent.Stage

Run the provided stage when the current stage ends, but does not complete.

A B C D E F G H I J L M N P R S T U W