Skip to main content

Function: runParallel()

runParallel<TInput, TOutput>(processors, options?): CallableProcessable<TInput, TOutput>

Defined in: packages/core/src/graph/parallel-merge.ts:210

Run processors in parallel over one input, merging the results.

Type Parameters

TInput

TInput = unknown

TOutput

TOutput = unknown

Parameters

processors

Processable<unknown, unknown>[]

options?

failureMode?

"fail-fast" | "settle"

input?

(data) => unknown

merge?

(input) => TOutput

Returns

CallableProcessable<TInput, TOutput>