Skip to main content

repeat

graphrefly_operators::control

Function repeat 

Source 
pub fn repeat(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    count: u32,
) -> NodeId
Expand description

Sequential resubscribe loop. Forwards all DATA from source. On source COMPLETE, if remaining > 0, resubscribes to source and decrements remaining. On ERROR, terminates immediately (no retry).

count is the number of ADDITIONAL subscriptions after the initial one. count = 0 is identity passthrough. count = 2 means the source will be subscribed up to 3 times total.