public class PullSubscriptionIntermediateFuture<E> extends SubscriptionIntermediateFuture<E> implements IPullSubscriptionIntermediateFuture<E>
IForwardCommandFuture.Type| Modifier and Type | Field and Description |
|---|---|
protected ICommand<PullSubscriptionIntermediateFuture<E>> |
pullcmd
The pull command.
|
ownresults, storeforfirstbcommands, 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 |
|---|
PullSubscriptionIntermediateFuture(java.lang.Exception exception)
Create a future that is already done (failed).
|
PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd)
Create a new future.
|
PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd,
ITerminationCommand termcom)
Create a new future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
pullIntermediateResult()
Pull an intermediate result.
|
addQuietListener, addResult, addResultListener, doGetNextIntermediateResult, hasNextIntermediateResultaddBackwardCommand, getTerminationCommand, removeBackwardCommand, sendBackwardCommand, setTerminationCommand, terminate, terminateaddIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, doAddIntermediateResult, doGetNextIntermediateResult, doNotifyListener, doSetFinished, doSetResult, flatMapAsync, getIntermediateResults, getNextIntermediateResult, getNextIntermediateResult, getNextIntermediateResult, 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, waitaddQuietListeneraddIntermediateResultListener, 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<PullSubscriptionIntermediateFuture<E>> pullcmd
public PullSubscriptionIntermediateFuture(java.lang.Exception exception)
exception - The exception.public PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd)
terminate - The runnable to be executed in case of termination.public PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd, ITerminationCommand termcom)
terminate - The runnable to be executed in case of termination.public void pullIntermediateResult()
pullIntermediateResult in interface IPullSubscriptionIntermediateFuture<E>