Function distinct_until_changed 

pub fn distinct_until_changed<S: Clone + 'static>(
    eq: impl Fn(&S, &S) -> bool + 'static,
) -> Operator<S>

distinct_until_changed: opt-in dedup at the operator layer (D49).