Skip to main content

combine

Function combine 

Source
pub fn combine(
    core: &Core,
    binding: &Arc<dyn OperatorBinding>,
    sources: &[NodeId],
    packer: PackerFn,
) -> Result<OperatorRegistration, OperatorFactoryError>
Expand description

combine(...sources) — combineLatest semantics.

Emits a packed tuple of the latest handle per dep whenever any dep fires. First-run gate (partial: false default) holds until all deps deliver real DATA (R2.5.3).

§Arguments

  • core — the Core dispatcher.
  • binding — implements OperatorBinding for closure registration.
  • sources — N dep node ids (order determines tuple position).
  • packer — closure that takes N HandleIds and returns a single tuple HandleId. The binding wraps Fn(&[T]) -> Tuple into this.

§Errors