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 |
addQuietListener(IResultListener<Collection<E>> listener)
Add a listener which is only informed about new results,
i.e. the initial results are not posted to this listener,
even if it is the first listener to be added to this future.
|
void |
addResultListener(IResultListener<Collection<E>> listener)
Add a result listener.
|
boolean |
hasNextIntermediateResult()
Check if there are more results for iteration for the given caller.
|
getTerminationCommand, setTerminationCommand, terminate, terminateaddIntermediateResult, addIntermediateResultIfUndone, getIntermediateResults, getNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndoneget, get, get, get, getEmptyFuture, getException, isDone, setException, setExceptionIfUndoneequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetIntermediateResults, getNextIntermediateResultterminate, terminatepublic SubscriptionIntermediateFuture()
public SubscriptionIntermediateFuture(Exception exception)
exception - The exception.public SubscriptionIntermediateFuture(ITerminationCommand terminate)
terminate - The code to be executed in case of termination.public void addQuietListener(IResultListener<Collection<E>> listener)
addQuietListener in interface ISubscriptionIntermediateFuture<E>public void addResultListener(IResultListener<Collection<E>> listener)
addResultListener in interface IFuture<Collection<E>>addResultListener in class IntermediateFuture<E>listsner - The listener.public boolean hasNextIntermediateResult()
hasNextIntermediateResult in interface IIntermediateFuture<E>hasNextIntermediateResult in class IntermediateFuture<E>Copyright © 2013. All Rights Reserved.