jadex.commons.future

Interface ISubscriptionIntermediateFuture<E>

All Superinterfaces:

IBackwardCommandFuture, IFuture<java.util.Collection<E>>, IIntermediateFuture<E>, ITerminableFuture<java.util.Collection<E>>, ITerminableIntermediateFuture<E>

All Known Subinterfaces:

IPullSubscriptionIntermediateFuture<E>

All Known Implementing Classes:

PullSubscriptionIntermediateDelegationFuture, PullSubscriptionIntermediateFuture, SubscriptionIntermediateDelegationFuture, SubscriptionIntermediateFuture

public interface ISubscriptionIntermediateFuture<E>
extends ITerminableIntermediateFuture<E>

The subscription intermediate future does not save the results but instead uses a fire and forget semantics. A listener gets current intermediate results in intermediateResultAvailable(). In getIntermediateResults() null is returned unless blocking access is also used.

Field Summary

Fields inherited from interface jadex.commons.future.IIntermediateFuture

DONE

Fields inherited from interface jadex.commons.future.IFuture

FALSE, TRUE

Method Summary

Modifier and Type	Method and Description
void	addQuietListener(IResultListener<java.util.Collection<E>> listener) Add a listener which does not consume the initial results.
java.util.Collection<E>	getIntermediateResults() Get the intermediate results that are available.

Methods inherited from interface jadex.commons.future.IIntermediateFuture

addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, addIntermediateResultListener, flatMapAsync, getNextIntermediateResult, getNextIntermediateResult, hasNextIntermediateResult, 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, delegate, exceptionally, exceptionally, exceptionally, get, get, get, get, get, getException, isDone, thenAccept, thenAccept, thenApply, thenApply, thenCombine, thenCompose, thenCompose

Methods inherited from interface jadex.commons.future.IBackwardCommandFuture

sendBackwardCommand

Method Detail

addQuietListener

void addQuietListener(IResultListener<java.util.Collection<E>> listener)

Add a listener which does not consume the initial results. I.e. even if it is the first listener to be added to this future, a second listener will still receive the initial results.

getIntermediateResults

java.util.Collection<E> getIntermediateResults()

Get the intermediate results that are available. Note: The semantics of this method is different to the normal intermediate future due to the fire-and-forget-semantics!

Specified by:

getIntermediateResults in interface IIntermediateFuture<E>

Returns:

1)