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, storeforfirst
notified, notify, reason, src, storedinfos
icallers, indices, intermediate, notcommand, results
CALLER_QUEUED, CALLER_RESUMED, CALLER_SUSPENDED, callers, creation, DEBUG, exception, first, listener, listeners, NO_STACK_COMPACTION, NONE, notifications, result, resultavailable, STACK, undone, UNSET
DONE
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, addResultListener, doGetNextIntermediateResult, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, storeResult
getSource, sendBackwardCommand, setSource, terminate, terminate
addIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, doAddIntermediateResult, doSetFinished, doSetResult, flatMapAsync, getNextIntermediateResult, getNextIntermediateResult, getNotificationCommand, hasNextIntermediateResult, mapAsync, mapAsync, notifyIntermediateResult, resume, resumeIntermediate, setFinished, setFinishedIfUndone
abortGet, acceptEither, addResultListener, addResultListener, applyToEither, delegate, doSetException, exceptionally, exceptionally, exceptionally, executeNotification, get, get, get, get, get, getEmptyFuture, getException, getFuture, hasResultListener, isDone, notifyListener, notifyListener, scheduleNotification, scheduleNotification, scheduleNotification, sendForwardCommand, setException, setExceptionIfUndone, setResult, setResultIfUndone, startScheduledNotifications, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addQuietListener, getIntermediateResults
addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, flatMapAsync, getNextIntermediateResult, getNextIntermediateResult, hasNextIntermediateResult, hasNextIntermediateResult, mapAsync, mapAsync
terminate, terminate
acceptEither, addResultListener, addResultListener, addResultListener, applyToEither, delegate, exceptionally, exceptionally, exceptionally, get, get, get, get, get, getException, isDone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose
sendBackwardCommand
public PullSubscriptionIntermediateDelegationFuture()
public PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<?> src)
protected void doNotify()
doNotify
in class TerminableIntermediateDelegationFuture<E>
public void pullIntermediateResult()
pullIntermediateResult
in interface IPullSubscriptionIntermediateFuture<E>