Package jadex.commons.future

Class PullSubscriptionIntermediateDelegationFuture<E>

java.lang.Object

jadex.commons.future.Future<java.util.Collection<E>>

jadex.commons.future.IntermediateFuture<E>

jadex.commons.future.TerminableIntermediateDelegationFuture<E>

jadex.commons.future.SubscriptionIntermediateDelegationFuture<E>

jadex.commons.future.PullSubscriptionIntermediateDelegationFuture<E>

All Implemented Interfaces:

IBackwardCommandFuture, IForwardCommandFuture, IFuture<java.util.Collection<E>>, IIntermediateFuture<E>, IPullIntermediateFuture<E>, IPullSubscriptionIntermediateFuture<E>, ISubscriptionIntermediateFuture<E>, ITerminableFuture<java.util.Collection<E>>, ITerminableIntermediateFuture<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.commons.future.IForwardCommandFuture

IForwardCommandFuture.Type

Field Summary

Fields inherited from class jadex.commons.future.SubscriptionIntermediateDelegationFuture

ownresults, resultssize, storeforfirst

Fields inherited from class jadex.commons.future.TerminableIntermediateDelegationFuture

handler

Fields inherited from class jadex.commons.future.IntermediateFuture

icallers, indices, intermediate, maxresultcnt, notcommand, results

Fields inherited from class jadex.commons.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.commons.future.IFuture

DONE, FALSE, TRUE

Fields inherited from interface jadex.commons.future.IIntermediateFuture

DONE

Constructor Summary

Constructors

Constructor	Description
PullSubscriptionIntermediateDelegationFuture()	Create a new future.
PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<E> src)	Create a new future.

Method Summary

Modifier and Type	Method	Description
void	pullIntermediateResult()	Pull an intermediate result.

Methods inherited from class jadex.commons.future.SubscriptionIntermediateDelegationFuture

addQuietListener, addResultListener, catchEx, catchEx, doGetNextIntermediateResult, finished, getIntermediateResults, getNextIntermediateResult, getResultCount, hasNextIntermediateResult, max, storeResult

Methods inherited from class jadex.commons.future.TerminableIntermediateDelegationFuture

delegateFrom, sendBackwardCommand, setTerminationSource, terminate, terminate

Methods inherited from class jadex.commons.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.commons.future.Future

abortGet, catchEx, delegate, delegateTo, doAddResultListener, doStartScheduledNotifications, executeNotification, get, get, get, get, get, getEmptyFuture, getException, getFuture, hasResultListener, isDone, isNotified, 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.commons.future.IBackwardCommandFuture

sendBackwardCommand

Methods inherited from interface jadex.commons.future.IFuture

addResultListener, catchEx, catchEx, catchEx, delegate, delegateTo, get, get, get, get, get, getException, isDone, then, thenApply, thenApply, thenCompose, thenCompose

Methods inherited from interface jadex.commons.future.IIntermediateFuture

asStream, asStream, done, finished, getNextIntermediateResult, getNextIntermediateResult, hasNextIntermediateResult, hasNextIntermediateResult, max, next

Methods inherited from interface jadex.commons.future.ISubscriptionIntermediateFuture

addQuietListener, getIntermediateResults

Methods inherited from interface jadex.commons.future.ITerminableFuture

terminate, terminate

Constructor Detail

PullSubscriptionIntermediateDelegationFuture

public PullSubscriptionIntermediateDelegationFuture()

Create a new future.

PullSubscriptionIntermediateDelegationFuture

public PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<E> src)

Create a new future.

Method Detail

pullIntermediateResult

public void pullIntermediateResult()

Pull an intermediate result.

Specified by:

pullIntermediateResult in interface IPullIntermediateFuture<E>

Specified by:

pullIntermediateResult in interface IPullSubscriptionIntermediateFuture<E>