MultiNode12
Models
Combinators
combineByNodeconstSuccessful values keyed by node.combineByNodeExitconstEvery peer exit keyed by node — keeps failures.combineCollectconstSuccessful values as an array (node order).combineFailuresconstThe nodes whose gather failed, with their cause.combineQueryconstGather a query field from every instance in peers (keyed by node), each call captured as a NodeResult — a down node becomes a failed exit, never a thrown gather — then combine.combineStreamconstCombine a stream field across every instance in peers: transform receives each node's stream (node-attributed) and produces the combined stream — e.g.combineSuccessesconstSuccessful per-node values, dropping the nodes that failed.combineSumconstSum of the successful numeric values.mergeNodeStreamsconstInterleave every node's stream into one (a transform for combineStream).mergeNodeStreamsByNodeconstInterleave every node's stream into one, tagging each element with its node — attribution when following peers (a transform for combineStream).