Skip to main content

window_time

graphrefly_operators::temporal

Function window_time 

Source 
pub fn window_time(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    ms: u64,
) -> NodeId
Expand description

Rotates sub-node windows every ms milliseconds.

Creates a new inner state node each interval tick. Upstream DATA is forwarded to the current inner window node. On tick, the current window is completed, a new inner node is created, and its identity is emitted as a DATA handle (via binding.intern_node).

  • On upstream COMPLETE: completes current window, then completes self.
  • On upstream ERROR: errors current window, then errors self.