Skip to main content

Function: parallelMerge()

parallelMerge<TOutput>(fanOut, branches, merge, processorNames?, failureMode?): Processable<unknown, TOutput>

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

Fan one input out to several branches and merge what comes back.

The graph is built once, when the processor is created: a fan-out step, one step per branch reading its slot, and a merge step joining the source, the fan-out and every branch. settle mode keeps a failed branch as a rejected slot so the merge still runs; fail-fast lets the failure surface.

Type Parameters

TOutput

TOutput = unknown

Parameters

fanOut

Processable

branches

Processable<unknown, unknown>[]

merge

Processable

processorNames?

string[]

failureMode?

"fail-fast" | "settle"

Returns

Processable<unknown, TOutput>