public class SubscriptionIntermediateDelegationFuture<E> extends TerminableIntermediateDelegationFuture<E> implements ISubscriptionIntermediateFuture<E>
IForwardCommandFuture.Type
DEBUG, EMPTY, NO_STACK_COMPACTION, STACK
DONE
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, terminate
addIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, getIntermediateResults, getNextIntermediateResult, getNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndone
abortGet, addForwardCommand, addResultListener, addResultListener, get, get, get, get, getEmptyFuture, getException, isDone, removeForwardCommand, sendForwardCommand, setException, setExceptionIfUndone
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, getIntermediateResults, getNextIntermediateResult
terminate, terminate
addResultListener, addResultListener, get, get, get, get, getException, isDone
sendBackwardCommand
public 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.