Struct WindowState 

pub struct WindowState {
    pub window_type: WindowType,
    pub events: Vec<WindowEvent>,
    pub window_start: u64,
    pub last_event_time: u64,
}

State for a window, buffering events and determining when to fire.

Fields

window_type: WindowType

events: Vec<WindowEvent>

window_start: u64

last_event_time: u64

Implementations

impl WindowState

pub fn new(window_type: WindowType) -> Self

pub fn add_event(&mut self, value: String, timestamp: u64)

Add an event to the window buffer.

pub fn should_fire(&self, current_time: u64) -> bool

Check if the window should fire (emit results).

pub fn fire(&mut self) -> Vec<WindowEvent>

Fire the window: drain events and reset. Returns the events that were in the window.

pub fn len(&self) -> usize

Number of buffered events.

pub fn is_empty(&self) -> bool

Whether the buffer is empty.

Trait Implementations

impl Debug for WindowState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.