Trait timely::progress::frontier::MutableAntichainFilter

pub trait MutableAntichainFilter<T: PartialOrder + Ord + Clone> {
    fn filter_through(
        self, 
        antichain: &mut MutableAntichain<T>
    ) -> Drain<(T, i64)>;
}

Extension trait for filtering time changes through antichains.

Required methods

fn filter_through(self, antichain: &mut MutableAntichain<T>) -> Drain<(T, i64)>

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)]);

Loading content...

Implementors

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

fn filter_through(self, antichain: &mut MutableAntichain<T>) -> Drain<(T, i64)>

Loading content...