| 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
|
| 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.
|
| 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.
|
| SResultListener |
Static helper class for creating result listeners.
|
| 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.
|