Class ChildrenExecutor<TOut, TScope>

Type Parameters

TOut = any
TScope = any

Index

Constructors

Methods

executeNodeChildren executeSelectedChildren

Constructors

constructor

new ChildrenExecutor<TOut = any, TScope = any>(
deps: HandlerDeps<TOut, TScope>,
executeNode: ExecuteNodeFn<TOut, TScope>,
): ChildrenExecutor<TOut, TScope>
Type Parameters
- TOut = any
- TScope = any
Parameters
- deps: HandlerDeps<TOut, TScope>
- executeNode: ExecuteNodeFn<TOut, TScope>
Returns ChildrenExecutor<TOut, TScope>
- Defined in lib/engine/handlers/ChildrenExecutor.ts:48

Methods

executeNodeChildren

executeNodeChildren(
    node: StageNode<TOut, TScope>,
    context: StageContext,
    parentBreakFlag?: { shouldBreak: boolean },
    branchPath?: string,
    traversalContext?: TraversalContext,
): Promise<Record<string, NodeResultType>>
Execute all children in parallel. Each child commits on settle. Uses Promise.allSettled to ensure all children complete even if some fail.
Parameters
- node: StageNode<TOut, TScope>
- context: StageContext
- OptionalparentBreakFlag: { shouldBreak: boolean }
- OptionalbranchPath: string
- OptionaltraversalContext: TraversalContext
Returns Promise<Record<string, NodeResultType>>
- Defined in lib/engine/handlers/ChildrenExecutor.ts:54

executeSelectedChildren

executeSelectedChildren(
    selector: Selector,
    children: StageNode<TOut, TScope>[],
    input: any,
    context: StageContext,
    branchPath: string,
    traversalContext?: TraversalContext,
    failFast?: boolean,
): Promise<Record<string, NodeResultType>>
Execute selected children based on selector result. Validates IDs, records selection info, then delegates to executeNodeChildren.
Parameters
- selector: Selector
- children: StageNode<TOut, TScope>[]
- input: any
- context: StageContext
- branchPath: string
- OptionaltraversalContext: TraversalContext
- OptionalfailFast: boolean
Returns Promise<Record<string, NodeResultType>>
- Defined in lib/engine/handlers/ChildrenExecutor.ts:201