jadex.commons.future

Class PullSubscriptionIntermediateFuture<E>

java.lang.Object

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

jadex.commons.future.IntermediateFuture<E>

jadex.commons.future.TerminableIntermediateFuture<E>

jadex.commons.future.SubscriptionIntermediateFuture<E>

jadex.commons.future.PullSubscriptionIntermediateFuture<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 PullSubscriptionIntermediateFuture<E>
extends SubscriptionIntermediateFuture<E>
implements IPullSubscriptionIntermediateFuture<E>

Intermediate future that can be terminated from caller side. A termination request leads to setException() being called with a FutureTerminatedException. The future can be supplied with a command that gets executed if terminate is called.

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 ICommand<PullSubscriptionIntermediateFuture<E>>	pullcmd The pull command.

Fields inherited from class jadex.commons.future.SubscriptionIntermediateFuture

ownresults, storeforfirst

Fields inherited from class jadex.commons.future.TerminableIntermediateFuture

bcommands, terminate

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, EMPTY, 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
PullSubscriptionIntermediateFuture(java.lang.Exception exception) Create a future that is already done (failed).
PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd) Create a new future.
PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd, ITerminationCommand termcom) Create a new future.

Method Summary

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

Methods inherited from class jadex.commons.future.SubscriptionIntermediateFuture

addQuietListener, addResult, addResultListener, doGetNextIntermediateResult, hasNextIntermediateResult

Methods inherited from class jadex.commons.future.TerminableIntermediateFuture

addBackwardCommand, getTerminationCommand, removeBackwardCommand, sendBackwardCommand, setTerminationCommand, 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, doSetResult, doSetResultIfUndone, 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, getException, isDone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose

Methods inherited from interface jadex.commons.future.IBackwardCommandFuture

sendBackwardCommand

Field Detail

pullcmd

protected ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd

The pull command.

Constructor Detail

PullSubscriptionIntermediateFuture

public PullSubscriptionIntermediateFuture(java.lang.Exception exception)

Create a future that is already done (failed).

Parameters:

exception - The exception.

PullSubscriptionIntermediateFuture

public PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd)

Create a new future.

Parameters:

terminate - The runnable to be executed in case of termination.

PullSubscriptionIntermediateFuture

public PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>> pullcmd,
                                          ITerminationCommand termcom)

Create a new future.

Parameters:

terminate - The runnable to be executed in case of termination.

Method Detail

pullIntermediateResult

public void pullIntermediateResult()

Pull an intermediate result.

Specified by:

pullIntermediateResult in interface IPullSubscriptionIntermediateFuture<E>