Trait timely::progress::frontier::MutableAntichainFilter

pub trait MutableAntichainFilter<T: PartialOrder + Ord + Clone> {
    // Required method
    fn filter_through(
        self,
        antichain: &mut MutableAntichain<T>,
    ) -> Drain<'_, [(T, i64); 2]>;
}

Extension trait for filtering time changes through antichains.

Required Methods

fn filter_through( self, antichain: &mut MutableAntichain<T>, ) -> Drain<'_, [(T, i64); 2]>

Filters time changes through an antichain.

Examples

use timely::progress::frontier::{MutableAntichain, MutableAntichainFilter};

let mut frontier = MutableAntichain::new_bottom(1u64);
let changes =
vec![(1, -1), (2, 7)]
    .filter_through(&mut frontier)
    .collect::<Vec<_>>();

assert!(changes == vec![(1, -1), (2, 1)]);

Implementors

impl<T: PartialOrder + Ord + Clone, I: IntoIterator<Item = (T, i64)>> MutableAntichainFilter<T> for I