Package jadex.commons.future
Class CollectionResultListener<E>
- java.lang.Object
-
- jadex.commons.future.CollectionResultListener<E>
-
- All Implemented Interfaces:
IResultListener<E>,IUndoneResultListener<E>
public class CollectionResultListener<E> extends java.lang.Object implements IResultListener<E>, IUndoneResultListener<E>
Collection result listener collects a number of results and return a collection.
-
-
Field Summary
Fields Modifier and Type Field Description protected IResultListener<java.util.Collection<E>>delegateThe delegate result listener.protected booleanignorefailuresFlag to indicate that failures should be ignored and only valid results returned.protected booleannotifiedFlag to indicate that the delegate already has been notified.protected static java.lang.ObjectNULLNull object.protected intnumThe number of sub listeners to wait for.protected java.util.Collection<E>resultsThe original result collection.protected booleanundoneThe undone flag.
-
Constructor Summary
Constructors Constructor Description CollectionResultListener(boolean ignorefailures, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener.CollectionResultListener(int num, boolean ignorefailures, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener.CollectionResultListener(int num, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener that stops on failures.CollectionResultListener(IResultListener<java.util.Collection<E>> delegate)Create a new collection listener that stops on failures.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected booleancheckNotify(E result, java.lang.Exception ex)Check if the delegate should be notified.voidexceptionOccurred(java.lang.Exception exception)Called when an exception occurred.voidexceptionOccurredIfUndone(java.lang.Exception exception)Called when an exception occurred.intgetResultCount()Get the result count.booleanisUndone()Get the undone.protected voidnotifyDelegate(java.lang.Exception exception)Notify the delegate.voidresultAvailable(E result)Called when some result is available.voidresultAvailableIfUndone(E result)Called when the result is available.voidsetNumber(int num)Set the expected number of results.
-
-
-
Field Detail
-
num
protected int num
The number of sub listeners to wait for.
-
results
protected java.util.Collection<E> results
The original result collection.
-
delegate
protected IResultListener<java.util.Collection<E>> delegate
The delegate result listener.
-
notified
protected boolean notified
Flag to indicate that the delegate already has been notified.
-
ignorefailures
protected boolean ignorefailures
Flag to indicate that failures should be ignored and only valid results returned.
-
undone
protected boolean undone
The undone flag.
-
NULL
protected static final java.lang.Object NULL
Null object.
-
-
Constructor Detail
-
CollectionResultListener
public CollectionResultListener(IResultListener<java.util.Collection<E>> delegate)
Create a new collection listener that stops on failures.- Parameters:
num- The expected number of results.delegate- The delegate result listener.
-
CollectionResultListener
public CollectionResultListener(boolean ignorefailures, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener.- Parameters:
num- The expected number of results.ignorefailures- When set to true failures will be tolerated and just not be added to the result collection.delegate- The delegate result listener.
-
CollectionResultListener
public CollectionResultListener(int num, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener that stops on failures.- Parameters:
num- The expected number of results.delegate- The delegate result listener.
-
CollectionResultListener
public CollectionResultListener(int num, boolean ignorefailures, IResultListener<java.util.Collection<E>> delegate)Create a new collection listener.- Parameters:
num- The expected number of results.ignorefailures- When set to true failures will be tolerated and just not be added to the result collection.delegate- The delegate result listener.
-
-
Method Detail
-
resultAvailable
public void resultAvailable(E result)
Called when some result is available.- Specified by:
resultAvailablein interfaceIResultListener<E>- Parameters:
result- The result.
-
exceptionOccurred
public void exceptionOccurred(java.lang.Exception exception)
Called when an exception occurred.- Specified by:
exceptionOccurredin interfaceIResultListener<E>- Parameters:
exception- The exception.
-
resultAvailableIfUndone
public void resultAvailableIfUndone(E result)
Called when the result is available.- Specified by:
resultAvailableIfUndonein interfaceIUndoneResultListener<E>- Parameters:
result- The result.
-
exceptionOccurredIfUndone
public void exceptionOccurredIfUndone(java.lang.Exception exception)
Called when an exception occurred.- Specified by:
exceptionOccurredIfUndonein interfaceIUndoneResultListener<E>- Parameters:
exception- The exception.
-
isUndone
public boolean isUndone()
Get the undone.- Returns:
- The undone.
-
getResultCount
public int getResultCount()
Get the result count.- Returns:
- The result count.
-
setNumber
public void setNumber(int num)
Set the expected number of results.- Parameters:
num- The expected number of results to set.
-
checkNotify
protected boolean checkNotify(E result, java.lang.Exception ex)
Check if the delegate should be notified.
-
notifyDelegate
protected void notifyDelegate(java.lang.Exception exception)
Notify the delegate.
-
-