public class SubscriptionIntermediateFuture<E> extends TerminableIntermediateFuture<E> implements ISubscriptionIntermediateFuture<E>
DEBUG, EMPTY, NO_STACK_COMPACTION, STACK
DONE
Constructor and Description |
---|
SubscriptionIntermediateFuture()
Create a new future.
|
SubscriptionIntermediateFuture(Exception exception)
Create a future that is already done (failed).
|
SubscriptionIntermediateFuture(ITerminationCommand terminate)
Create a new future.
|
Modifier and Type | Method and Description |
---|---|
void |
addResultListener(IResultListener<Collection<E>> listener)
Add a result listener.
|
getTerminationCommand, setTerminationCommand, terminate, terminate
addIntermediateResult, addIntermediateResultIfUndone, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndone
get, get, getEmptyFuture, getException, isDone, setException, setExceptionIfUndone
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult
terminate, terminate
get, get, getException, isDone
public SubscriptionIntermediateFuture()
public SubscriptionIntermediateFuture(Exception exception)
exception
- The exception.public SubscriptionIntermediateFuture(ITerminationCommand terminate)
terminate
- The code to be executed in case of termination.public void addResultListener(IResultListener<Collection<E>> listener)
addResultListener
in interface IFuture<Collection<E>>
addResultListener
in class IntermediateFuture<E>
listsner
- The listener.Copyright © 2012. All Rights Reserved.