Package jadex.future
Class PullSubscriptionIntermediateDelegationFuture<E>
java.lang.Object
jadex.future.Future<Collection<E>>
jadex.future.IntermediateFuture<E>
jadex.future.TerminableIntermediateDelegationFuture<E>
jadex.future.SubscriptionIntermediateDelegationFuture<E>
jadex.future.PullSubscriptionIntermediateDelegationFuture<E>
- All Implemented Interfaces:
IBackwardCommandFuture
,IForwardCommandFuture
,IFuture<Collection<E>>
,IIntermediateFuture<E>
,IPullIntermediateFuture<E>
,IPullSubscriptionIntermediateFuture<E>
,ISubscriptionIntermediateFuture<E>
,ITerminableFuture<Collection<E>>
,ITerminableIntermediateFuture<E>
,Supplier<Collection<E>>
public class PullSubscriptionIntermediateDelegationFuture<E>
extends SubscriptionIntermediateDelegationFuture<E>
implements IPullSubscriptionIntermediateFuture<E>, IPullIntermediateFuture<E>
Delegation future for pull future.
-
Nested Class Summary
Nested classes/interfaces inherited from interface jadex.future.IForwardCommandFuture
IForwardCommandFuture.Type
-
Field Summary
Fields inherited from class jadex.future.SubscriptionIntermediateDelegationFuture
ownresults, resultssize, storeforfirst
Fields inherited from class jadex.future.TerminableIntermediateDelegationFuture
handler
Fields inherited from class jadex.future.IntermediateFuture
icallers, indices, intermediate, maxresultcnt, notcommand, results
Fields inherited from class jadex.future.Future
CALLER_QUEUED, CALLER_RESUMED, CALLER_SUSPENDED, callers, creation, DEBUG, exception, first, listeners, NO_STACK_COMPACTION, NONE, NOTIFICATIONS, notificount, notified, result, resultavailable, undone, UNSET
Fields inherited from interface jadex.future.IIntermediateFuture
DONE
-
Constructor Summary
ConstructorsConstructorDescriptionCreate a new future.Create a new future. -
Method Summary
Methods inherited from class jadex.future.SubscriptionIntermediateDelegationFuture
addQuietListener, addResultListener, catchEx, catchEx, doGetNextIntermediateResult, finished, getIntermediateResults, getNextIntermediateResult, getResultCount, hasNextIntermediateResult, max, storeResult
Methods inherited from class jadex.future.TerminableIntermediateDelegationFuture
delegateFrom, sendBackwardCommand, setTerminationSource, terminate, terminate
Methods inherited from class jadex.future.IntermediateFuture
addIntermediateResult, addIntermediateResultIfUndone, asStream, asStream, delegateEx, doAddIntermediateResult, done, doSetException, doSetFinished, doSetResult, getNextIntermediateResult, getNextIntermediateResult, getNotificationCommand, hasNextIntermediateResult, next, notifyIntermediateResult, resume, resumeIntermediate, scheduleMaxNotification, setFinished, setFinishedIfUndone, setMaxResultCount, then
Methods inherited from class jadex.future.Future
abortGet, catchEx, delegate, delegateTo, doAddResultListener, doStartScheduledNotifications, executeNotification, get, get, get, get, get, getEmptyFuture, getException, getFuture, hasResultListener, isDone, isNotified, printOnEx, scheduleNotification, scheduleNotification, sendForwardCommand, setException, setExceptionIfUndone, setResult, setResultIfUndone, startScheduledNotifications, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose, throwException
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface jadex.future.IBackwardCommandFuture
sendBackwardCommand
Methods inherited from interface jadex.future.IFuture
addResultListener, catchEx, catchEx, catchEx, delegate, delegateTo, get, get, get, get, get, getException, isDone, printOnEx, then, thenApply, thenApply, thenCompose, thenCompose
Methods inherited from interface jadex.future.IIntermediateFuture
asStream, asStream, done, finished, getNextIntermediateResult, getNextIntermediateResult, hasNextIntermediateResult, hasNextIntermediateResult, max, next
Methods inherited from interface jadex.future.ISubscriptionIntermediateFuture
addQuietListener, getIntermediateResults
Methods inherited from interface jadex.future.ITerminableFuture
terminate, terminate
-
Constructor Details
-
PullSubscriptionIntermediateDelegationFuture
public PullSubscriptionIntermediateDelegationFuture()Create a new future. -
PullSubscriptionIntermediateDelegationFuture
Create a new future.
-
-
Method Details
-
pullIntermediateResult
public void pullIntermediateResult()Pull an intermediate result.- Specified by:
pullIntermediateResult
in interfaceIPullIntermediateFuture<E>
- Specified by:
pullIntermediateResult
in interfaceIPullSubscriptionIntermediateFuture<E>
-