Skip to main content

concat

graphrefly_operators::ops_impl

Function concat 

Source 
pub fn concat(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    first: NodeId,
    second: NodeId,
) -> NodeId
Expand description

concat(first, second) — forward DATA from first until it completes, then drain any DATA second emitted during phase 1 (buffered) and continue forwarding second. ERROR from either source terminates the producer with the same ERROR.

Subscribes to BOTH sources at activation time (matches TS impl in extra/operators/combine.ts:332-379 so second.subscribe doesn’t race after first completes). DATA from second during phase 0 is buffered, not forwarded.