public class SubscriptionIntermediateFuture<E> extends TerminableIntermediateFuture<E> implements ISubscriptionIntermediateFuture<E>
IForwardCommandFuture.Type
DEBUG, EMPTY, NO_STACK_COMPACTION, STACK
DONE
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.
|
void |
addResultListener(IResultListener<Collection<E>> listener)
Add a result listener.
|
boolean |
hasNextIntermediateResult()
Check if there are more results for iteration for the given caller.
|
addBackwardCommand, getTerminationCommand, removeBackwardCommand, sendBackwardCommand, setTerminationCommand, 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 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 © 2015. All Rights Reserved.