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)
IIntermediateResultListener
intermediateResultAvailable
in interface IFunctionalIntermediateResultListener<E>
intermediateResultAvailable
in interface IIntermediateResultListener<E>
result
- The result.public void finished()
IIntermediateResultListener
finished
in interface IFunctionalIntermediateFinishedListener
finished
in interface IIntermediateResultListener<E>
public void resultAvailable(java.util.Collection<E> results)
IIntermediateResultListener
resultAvailable
in interface IFunctionalResultListener<java.util.Collection<E>>
resultAvailable
in interface IIntermediateResultListener<E>
results
- The final result.public void exceptionOccurred(java.lang.Exception exception)
IFunctionalExceptionListener
exceptionOccurred
in interface IFunctionalExceptionListener
exception
- The exception.