Skip to main content

window_count

Function window_count 

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

Like window but closes window every count DATA items.

  • On activation: create first window, emit it.
  • Source DATA: forward to current window + increment counter. When counter hits count, complete current window, create new one, emit it, reset counter.
  • Source COMPLETE: complete current window (even if < count items), complete self.
  • Source ERROR: error current window, error self.

§Panics

Panics if count is 0.