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 result available null is returned. In getIntermediateResults() null is returned.

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.

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