public class PullIntermediateFuture<E> extends TerminableIntermediateFuture<E> implements IPullIntermediateFuture<E>
IForwardCommandFuture.Type| Modifier and Type | Field and Description |
|---|---|
protected ICommand<PullIntermediateFuture<E>> |
pullcmd
The pull command.
|
bcommands, terminateicallers, indices, intermediate, results, scheduledCALLER_QUEUED, CALLER_RESUMED, CALLER_SUSPENDED, callers, creation, DEBUG, exception, fcommands, first, listener, listeners, NO_STACK_COMPACTION, NONE, result, resultavailable, STACK, undone, UNSETDONE| Constructor and Description |
|---|
PullIntermediateFuture()
Create a new future.
|
PullIntermediateFuture(java.lang.Exception exception)
Create a future that is already done (failed).
|
PullIntermediateFuture(ICommand<PullIntermediateFuture<E>> pullcmd)
Create a new future.
|
PullIntermediateFuture(ICommand<PullIntermediateFuture<E>> pullcmd,
ITerminationCommand termcom)
Create a new future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
pullIntermediateResult()
Pull an intermediate result.
|
addBackwardCommand, getTerminationCommand, removeBackwardCommand, sendBackwardCommand, setTerminationCommand, terminate, terminateaddIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addResult, addResultListener, doAddIntermediateResult, doGetNextIntermediateResult, doNotifyListener, doSetFinished, doSetResult, flatMapAsync, getIntermediateResults, getNextIntermediateResult, getNextIntermediateResult, getNextIntermediateResult, hasNextIntermediateResult, mapAsync, mapAsync, notifyIntermediateResult, notifyListener, resume, resumeIntermediate, scheduleNotification, setFinished, setFinishedIfUndone, startScheduledNotificationsabortGet, acceptEither, addForwardCommand, addResultListener, addResultListener, applyToEither, doSetException, get, get, get, get, get, getEmptyFuture, getException, getFuture, hasResultListener, isDone, notifyListenerCommand, removeForwardCommand, sendForwardCommand, setException, setExceptionIfUndone, setResult, setResultIfUndone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenComposeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, flatMapAsync, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, mapAsync, mapAsyncterminate, terminateacceptEither, addResultListener, addResultListener, addResultListener, applyToEither, get, get, get, get, get, getException, isDone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenComposesendBackwardCommandprotected ICommand<PullIntermediateFuture<E>> pullcmd
public PullIntermediateFuture()
public PullIntermediateFuture(java.lang.Exception exception)
exception - The exception.public PullIntermediateFuture(ICommand<PullIntermediateFuture<E>> pullcmd)
terminate - The runnable to be executed in case of termination.public PullIntermediateFuture(ICommand<PullIntermediateFuture<E>> pullcmd, ITerminationCommand termcom)
terminate - The runnable to be executed in case of termination.public void pullIntermediateResult()
pullIntermediateResult in interface IPullIntermediateFuture<E>