public class PullSubscriptionIntermediateDelegationFuture<E> extends SubscriptionIntermediateDelegationFuture<E> implements IPullSubscriptionIntermediateFuture<E>
IForwardCommandFuture.Type| Modifier and Type | Field and Description |
|---|---|
protected int |
notifycnt
Flag if source has to be notified.
|
ownresults, storeforfirstnotified, notify, reason, src, storedinfosicallers, 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 |
|---|
PullSubscriptionIntermediateDelegationFuture()
Create a new future.
|
PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<?> src)
Create a new future.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
doNotify()
Possibly notify the termination source.
|
void |
pullIntermediateResult()
Pull an intermediate result.
|
addQuietListener, addResult, addResultListener, doGetNextIntermediateResult, hasNextIntermediateResultgetSource, sendBackwardCommand, setSource, 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, thenComposesendBackwardCommandpublic PullSubscriptionIntermediateDelegationFuture()
public PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<?> src)
protected void doNotify()
doNotify in class TerminableIntermediateDelegationFuture<E>public void pullIntermediateResult()
pullIntermediateResult in interface IPullSubscriptionIntermediateFuture<E>