Embabel Agent Documentation/com.embabel.agent.api.common.workflow.control/ScatterGather

ScatterGather

class ScatterGather(maxConcurrency: Int)

Scatter gather pattern for generating multiple results in parallel and consolidating them.

Constructors

constructor(maxConcurrency: Int)

Functions

fun <ELEMENT : Any, RESULT : Any> forkJoin(generators: List<(SupplierActionContext<ELEMENT>) -> ELEMENT>, joinFunction: (TransformationActionContext<ResultList<ELEMENT>, RESULT>) -> RESULT, elementClass: Class<ELEMENT>, resultClass: Class<RESULT>): AgentScopeBuilder<RESULT>