public class SubscriptionIntermediateDelegationFuture<E> extends TerminableIntermediateDelegationFuture<E> implements ISubscriptionIntermediateFuture<E>
IForwardCommandFuture.TypeDEBUG, EMPTY, NO_STACK_COMPACTION, STACKDONE| Constructor and Description |
|---|
SubscriptionIntermediateDelegationFuture()
Create a new future.
|
SubscriptionIntermediateDelegationFuture(ITerminableIntermediateFuture<?> src)
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.
|
void |
addResultListener(IResultListener<Collection<E>> listener)
Add a result listener.
|
boolean |
hasNextIntermediateResult()
Check if there are more results for iteration for the given caller.
|
getSource, sendBackwardCommand, setSource, terminate, terminateaddIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, getIntermediateResults, getNextIntermediateResult, getNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndoneabortGet, addForwardCommand, addResultListener, addResultListener, get, get, get, get, getEmptyFuture, getException, isDone, removeForwardCommand, sendForwardCommand, setException, setExceptionIfUndoneequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, getIntermediateResults, getNextIntermediateResultterminate, terminateaddResultListener, addResultListener, get, get, get, get, getException, isDonesendBackwardCommandpublic SubscriptionIntermediateDelegationFuture()
public SubscriptionIntermediateDelegationFuture(ITerminableIntermediateFuture<?> src)
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 © 2015. All Rights Reserved.