Class ScatterGather
-
- All Implemented Interfaces:
public final class ScatterGatherScatter gather pattern for generating multiple results in parallel and consolidating them.
-
-
Constructor Summary
Constructors Constructor Description ScatterGather(Integer maxConcurrency)
-
Method Summary
Modifier and Type Method Description final <ELEMENT extends Any, RESULT extends Any> AgentScopeBuilder<RESULT>forkJoin(List<Function1<SupplierActionContext<ELEMENT>, ELEMENT>> generators, Function1<TransformationActionContext<ResultList<ELEMENT>, RESULT>, RESULT> joinFunction, Class<ELEMENT> elementClass, Class<RESULT> resultClass)-
-
Constructor Detail
-
ScatterGather
ScatterGather(Integer maxConcurrency)
-
-
Method Detail
-
forkJoin
final <ELEMENT extends Any, RESULT extends Any> AgentScopeBuilder<RESULT> forkJoin(List<Function1<SupplierActionContext<ELEMENT>, ELEMENT>> generators, Function1<TransformationActionContext<ResultList<ELEMENT>, RESULT>, RESULT> joinFunction, Class<ELEMENT> elementClass, Class<RESULT> resultClass)
-
-
-
-