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. 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.
|
getSource, sendBackwardCommand, setSource, terminate, terminateaddIntermediateResult, addIntermediateResultIfUndone, getIntermediateResults, getNextIntermediateResult, getNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndoneabortGet, addForwardCommand, get, get, get, get, getEmptyFuture, getException, isDone, removeForwardCommand, sendForwardCommand, setException, setExceptionIfUndoneequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetIntermediateResults, getNextIntermediateResultterminate, terminateget, 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 © 2013. All Rights Reserved.