Struct PunctuatedGenerator 

pub struct PunctuatedGenerator<F>
where
    F: Fn(i64) -> Option<Watermark> + Send,
{ /* private fields */ }

Punctuated watermark generator that emits based on special events.

Uses a predicate function to identify watermark-carrying events. When the predicate returns Some(watermark), that watermark is emitted.

Example

use laminar_core::time::{PunctuatedGenerator, WatermarkGenerator, Watermark};

// Emit watermark on every 1000ms boundary
let mut gen = PunctuatedGenerator::new(|ts| {
    if ts % 1000 == 0 {
        Some(Watermark::new(ts))
    } else {
        None
    }
});

assert_eq!(gen.on_event(999), None);
assert_eq!(gen.on_event(1000), Some(Watermark::new(1000)));

Implementations

impl<F> PunctuatedGenerator<F>

where F: Fn(i64) -> Option<Watermark> + Send,

pub fn new(predicate: F) -> Self

Creates a new punctuated generator with the given predicate.

Arguments

• predicate - Function that returns Some(Watermark) for watermark events

Trait Implementations

impl<F> WatermarkGenerator for PunctuatedGenerator<F>

where F: Fn(i64) -> Option<Watermark> + Send,

fn on_event(&mut self, timestamp: i64) -> Option<Watermark>

Process an event timestamp and potentially emit a new watermark.

fn on_periodic(&mut self) -> Option<Watermark>

Called periodically to emit watermarks based on wall-clock time.

fn current_watermark(&self) -> i64

Returns the current watermark value without advancing it.