public class SubscriptionIntermediateFuture<E> extends TerminableIntermediateFuture<E> implements ISubscriptionIntermediateFuture<E>
DEBUG, EMPTY, NO_STACK_COMPACTION, STACKDONE| 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, terminateaddIntermediateResult, addIntermediateResultIfUndone, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndoneget, get, getEmptyFuture, getException, isDone, setException, setExceptionIfUndoneequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetIntermediateResults, getNextIntermediateResult, hasNextIntermediateResultterminate, terminateget, get, getException, isDonepublic 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.