public class FlattenMultiplexCollector extends java.lang.Object implements IMultiplexCollector
Modifier and Type | Field and Description |
---|---|
protected java.util.List<java.lang.Object> |
callresults
The list of results (if ret is not intermediate future).
|
protected java.util.List<jadex.commons.future.Future<java.lang.Void>> |
calls
The list of calls.
|
protected boolean |
flatten
Flag if flatten.
|
protected jadex.commons.future.Future<java.lang.Object> |
fut
The future.
|
Constructor and Description |
---|
FlattenMultiplexCollector() |
Modifier and Type | Method and Description |
---|---|
protected void |
addResult(java.lang.Object result)
Add a result.
|
void |
exceptionOccurred(java.lang.Exception exception) |
void |
finished() |
void |
init(jadex.commons.future.Future<java.lang.Object> fut,
java.lang.reflect.Method method,
java.lang.Object[] args,
java.lang.reflect.Method muxmethod)
Init to share code.
|
void |
intermediateResultAvailable(java.lang.Object result) |
void |
resultAvailable(java.util.Collection<java.lang.Object> result) |
protected void |
setException(java.lang.Exception exception)
Set an exception.
|
protected void |
setFinished()
Set finished.
|
protected jadex.commons.future.Future<java.lang.Object> fut
protected boolean flatten
protected java.util.List<jadex.commons.future.Future<java.lang.Void>> calls
protected java.util.List<java.lang.Object> callresults
public void init(jadex.commons.future.Future<java.lang.Object> fut, java.lang.reflect.Method method, java.lang.Object[] args, java.lang.reflect.Method muxmethod)
init
in interface IMultiplexCollector
public void intermediateResultAvailable(java.lang.Object result)
intermediateResultAvailable
in interface jadex.commons.future.IFunctionalIntermediateResultListener<java.lang.Object>
intermediateResultAvailable
in interface jadex.commons.future.IIntermediateResultListener<java.lang.Object>
public void finished()
finished
in interface jadex.commons.future.IFunctionalIntermediateFinishedListener
finished
in interface jadex.commons.future.IIntermediateResultListener<java.lang.Object>
public void resultAvailable(java.util.Collection<java.lang.Object> result)
resultAvailable
in interface jadex.commons.future.IFunctionalResultListener<java.util.Collection<java.lang.Object>>
resultAvailable
in interface jadex.commons.future.IIntermediateResultListener<java.lang.Object>
public void exceptionOccurred(java.lang.Exception exception)
exceptionOccurred
in interface jadex.commons.future.IFunctionalExceptionListener
protected void addResult(java.lang.Object result)
result
- The result.protected void setFinished()
protected void setException(java.lang.Exception exception)
exception
- The exception.