Skip to main content

Interface: ParallelConfig<TInput, TOutput, TProcessors>

Defined in: packages/core/src/pipeline/types.ts:209

Type Parameters​

TInput​

TInput

TOutput​

TOutput

TProcessors​

TProcessors extends ParallelProcessors = ParallelProcessors

Properties​

input?​

optional input?: (data) => any

Defined in: packages/core/src/pipeline/types.ts:223

Optional input transformation before fanning out to processors

Parameters​

data​

TInput

Returns​

any

merge?​

optional merge?: (mergeInput) => TOutput

Defined in: packages/core/src/pipeline/types.ts:229

Function to merge parallel results into output. Receives ParallelMergeInput with results, original input, bot names.

Parameters​

mergeInput​

ParallelMergeInput<ParallelResults<TProcessors>, TInput, any>

Returns​

TOutput

processors​

processors: TProcessors

Defined in: packages/core/src/pipeline/types.ts:220

Processors to run in parallel. Can be:

  • Object: Named processors with string keys
  • Array: List of processors Functions are auto-wrapped as processables.