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>, IPullSubscriptionIntermediateFuture<E>, ISubscriptionIntermediateFuture<E>, ITerminableFuture<java.util.Collection<E>>, ITerminableIntermediateFuture<E>

public class PullSubscriptionIntermediateDelegationFuture<E>
extends SubscriptionIntermediateDelegationFuture<E>
implements IPullSubscriptionIntermediateFuture<E>

Delegation future for pull future.

Nested Class Summary

Nested classes/interfaces inherited from interface jadex.commons.future.IForwardCommandFuture

IForwardCommandFuture.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected int	notifycnt Flag if source has to be notified.

Fields inherited from class jadex.commons.future.SubscriptionIntermediateDelegationFuture

ownresults, storeforfirst

Fields inherited from class jadex.commons.future.TerminableIntermediateDelegationFuture

notified, notify, reason, src, storedinfos

Fields inherited from class jadex.commons.future.IntermediateFuture

icallers, indices, intermediate, results, scheduled

Fields inherited from class jadex.commons.future.Future

CALLER_QUEUED, CALLER_RESUMED, CALLER_SUSPENDED, callers, creation, DEBUG, exception, fcommands, first, listener, listeners, NO_STACK_COMPACTION, NONE, result, resultavailable, STACK, undone, UNSET

Fields inherited from interface jadex.commons.future.IIntermediateFuture

DONE

Fields inherited from interface jadex.commons.future.IFuture

FALSE, TRUE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	doNotify() Possibly notify the termination source.
void	pullIntermediateResult() Pull an intermediate result.

Methods inherited from class jadex.commons.future.SubscriptionIntermediateDelegationFuture

addQuietListener, addResult, addResultListener, doGetNextIntermediateResult, hasNextIntermediateResult

Methods inherited from class jadex.commons.future.TerminableIntermediateDelegationFuture

getSource, sendBackwardCommand, setSource, terminate, terminate

Methods inherited from class jadex.commons.future.IntermediateFuture

addIntermediateResult, addIntermediateResultIfUndone, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, doNotifyListener, flatMapAsync, getIntermediateResults, getNextIntermediateResult, mapAsync, mapAsync, notifyIntermediateResult, notifyListener, resume, resumeIntermediate, scheduleNotification, setFinished, setFinishedIfUndone, setResult, setResultIfUndone, startScheduledNotifications

Methods inherited from class jadex.commons.future.Future

abortGet, acceptEither, addForwardCommand, addResultListener, addResultListener, applyToEither, doSetException, doSetResult, get, get, get, getEmptyFuture, getException, getFuture, hasResultListener, isDone, notifyListenerCommand, removeForwardCommand, sendForwardCommand, setException, setExceptionIfUndone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose

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.ISubscriptionIntermediateFuture

addQuietListener

Methods inherited from interface jadex.commons.future.IIntermediateFuture

addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, flatMapAsync, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, mapAsync, mapAsync

Methods inherited from interface jadex.commons.future.ITerminableFuture

terminate, terminate

Methods inherited from interface jadex.commons.future.IFuture

acceptEither, addResultListener, addResultListener, addResultListener, applyToEither, get, get, get, getException, isDone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose

Methods inherited from interface jadex.commons.future.IBackwardCommandFuture

sendBackwardCommand

Field Detail

notifycnt

protected int notifycnt

Flag if source has to be notified.

Constructor Detail

PullSubscriptionIntermediateDelegationFuture

public PullSubscriptionIntermediateDelegationFuture()

Create a new future.

PullSubscriptionIntermediateDelegationFuture

public PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<?> src)

Create a new future.

Method Detail

doNotify

protected void doNotify()

Possibly notify the termination source.

Overrides:

doNotify in class TerminableIntermediateDelegationFuture<E>

pullIntermediateResult

public void pullIntermediateResult()

Pull an intermediate result.

Specified by:

pullIntermediateResult in interface IPullSubscriptionIntermediateFuture<E>