Skip to main content

settle

graphrefly_operators::control

Function settle 

Source 
pub fn settle(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    quiet_waves: u32,
    max_waves: Option<u32>,
) -> NodeId
Expand description

Wave-count convergence detector.

  • On DATA: resets quiet_count to 0, increments wave_count. Forwards DATA unchanged. If max_waves is set and wave_count >= max_waves, completes.
  • On RESOLVED (tier 3, no payload): increments quiet_count. If quiet_count >= quiet_waves, completes.
  • On COMPLETE/ERROR: forwarded unchanged.