CallMultiplexer |
The CallMultiplexer unifies multiple executions of "similar" commands to a single execution.
|
CallSequentializer<T> |
The call sequentializer realizes a 'critical region' for async calls,
i.e.
|
CollectingIntermediateResultListener<E> |
A listener that collects intermediate results and calls resultAvailable() on setFinished().
|
CollectionResultListener<E> |
Collection result listener collects a number of results and return a collection.
|
CounterResultListener<E> |
Counter result listener for counting a specified number of resultAvailable calls.
|
DefaultResultListener<E> |
The default listener for logging exceptions as warning.
|
DefaultTuple2ResultListener<E,F> |
Default tuple2 result listener that implements the
(obsolete) methods
- resultAvailable
- intermediateResultAvailable
- finished
- resultCountAvailable
|
DelegationResultListener<E> |
Result listener that delegates calls to a future.
|
DuplicateRemovalIntermediateResultListener<E> |
A result listener that filters duplicates.
|
ExceptionDelegationResultListener<E,T> |
Result listener that delegates calls to a future.
|
ExceptionResultListener<E> |
The exception listener is used for intercepting exceptions while ignoring results.
|
Future<E> |
Future that includes mechanisms for callback notification.
|
FutureBarrier<E> |
A future barrier allows for waiting for a variable number
of futures.
|
FutureFinishChecker |
Allows monitoring a number of tasks (futures) and get a
notification when set to finished (no more new tasks)
and all tasks have been processed (futures notified).
|
FutureHelper |
Helper class to access future notification stack
|
IntermediateDefaultResultListener<E> |
The default listener for just printing out result information.
|
IntermediateDelegationResultListener<E> |
Intermediate version of the delegation result listener.
|
IntermediateEmptyResultListener<E> |
Empty implementation of the intermediate result listener.
|
IntermediateExceptionDelegationResultListener<E,T> |
Exception delegation listener for intermediate futures.
|
IntermediateFuture<E> |
Default implementation of an intermediate future.
|
IntermediateFutureIterator<E> |
Helper class for iterating over the results of an intermediate future.
|
PullIntermediateDelegationFuture<E> |
Delegation future for pull future.
|
PullIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
PullSubscriptionIntermediateDelegationFuture<E> |
Delegation future for pull future.
|
PullSubscriptionIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
RemoteDelegationResultListener<E> |
Result listener that delegates calls to a future
and can be called from remote.
|
SubscriptionIntermediateDelegationFuture<E> |
|
SubscriptionIntermediateFuture<E> |
Implementation of the subscription intermediate future.
|
TerminableDelegationFuture<E> |
A terminable delegation future can be used when a termination future
should be delegated.
|
TerminableDelegationResultListener<E> |
Result listener for terminable futures.
|
TerminableFuture<E> |
Future that can be terminated from caller side.
|
TerminableIntermediateDelegationFuture<E> |
A terminable intermediate delegation future can be used when a termination intermediate future
should be delegated.
|
TerminableIntermediateDelegationResultListener<E> |
Result listener for terminable intermediate futures.
|
TerminableIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
TerminationCommand |
Base implementation of termination command to be used for sub-classing.
|
ThreadLocalTransferHelper |
Helps to transfer registered thread local values between different threads.
|
ThreadSuspendable |
Suspendable for threads.
|
Tuple2Future<E,F> |
Implementation of tuple2 future.
|
TupleResult |
Used by tuple futures as internal result wrappers.
|
UnlimitedIntermediateDelegationResultListener<E> |
Listener that forwards results but not finished events.
|