public static class ServiceRegistry.UnlimitedIntermediateDelegationResultListener<E> extends java.lang.Object implements IIntermediateResultListener<E>
| Modifier and Type | Field and Description |
|---|---|
protected IntermediateFuture<E> |
delegate
The delegate future.
|
| Constructor and Description |
|---|
UnlimitedIntermediateDelegationResultListener(IntermediateFuture<E> delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
exceptionOccurred(java.lang.Exception exception)
Called when an exception occurred.
|
void |
finished()
Declare that the future is finished.
|
void |
intermediateResultAvailable(E result)
Called when an intermediate result is available.
|
void |
resultAvailable(java.util.Collection<E> results)
Called when the result is available.
|
protected IntermediateFuture<E> delegate
public UnlimitedIntermediateDelegationResultListener(IntermediateFuture<E> delegate)
public void intermediateResultAvailable(E result)
IIntermediateResultListenerintermediateResultAvailable in interface IFunctionalIntermediateResultListener<E>intermediateResultAvailable in interface IIntermediateResultListener<E>result - The result.public void finished()
IIntermediateResultListenerfinished in interface IFunctionalIntermediateFinishedListenerfinished in interface IIntermediateResultListener<E>public void resultAvailable(java.util.Collection<E> results)
IIntermediateResultListenerresultAvailable in interface IFunctionalResultListener<java.util.Collection<E>>resultAvailable in interface IIntermediateResultListener<E>results - The final result.public void exceptionOccurred(java.lang.Exception exception)
IFunctionalExceptionListenerexceptionOccurred in interface IFunctionalExceptionListenerexception - The exception.