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— implementsOperatorBindingfor closure registration.sources— N dep node ids (order determines tuple position).packer— closure that takes NHandleIds and returns a single tupleHandleId. The binding wrapsFn(&[T]) -> Tupleinto this.
§Errors
OperatorFactoryError::EmptySources—sourcesis empty.OperatorFactoryError::Register— Core-layer registration error (unknown / terminal-non-resubscribable dep).