T
- This type parameter identifies the type of the data object which
will be passed into the deferred concentrator via the input deferred
event objects.public interface DeferredConcentrator<T>
A callback will be generated by the output deferred event only if all input deferred events completed successfully. In this case, the callback parameter will be an array list containing the callback data returned by each of the input callback chains, listed according to the order in which the deferred event objects were added.
If an errback is encountered on any of the input deferred events, it will be propagated to the output callback chain and all other results will be discarded. Only the first errback condition to be generated will be passed back in this way.
Modifier and Type | Method and Description |
---|---|
void |
addInputDeferred(Deferred<T> deferred)
Adds an input deferred event object to the concentrator list.
|
Deferred<java.util.List<T>> |
getOutputDeferred()
Accesses the output deferred event object for the concentrator list.
|
void addInputDeferred(Deferred<T> deferred) throws DeferredTerminationException
deferred
- This is the deferred event object which is to be added to the
concentrator list.DeferredTerminationException
- This exception is thrown if the deferred event object being
passed as the parameter has already had its callback chain
terminated, or the output deferred event object has already been
requested which prevents further additions to the list.Deferred<java.util.List<T>> getOutputDeferred()