Struct coord::coord::antichain::AntichainToken[−][src]

pub struct AntichainToken<T: PartialOrder + Ord + Clone> {
    antichain: MutableAntichain<T>,
    changes: Rc<RefCell<ChangeBatch<T>>>,
    action: Rc<RefCell<dyn FnMut(Drain<'_, (T, i64)>)>>,
}

Expand description

A token that holds a mutable antichain and invokes an action should it change.

Fields

antichain: MutableAntichain<T>changes: Rc<RefCell<ChangeBatch<T>>>action: Rc<RefCell<dyn FnMut(Drain<'_, (T, i64)>)>>

Implementations

[src]

impl<T: PartialOrder + Ord + Clone + Debug> AntichainToken<T>

[src]

pub fn new<I, F>(values: I, action: F) -> Self where
I: IntoIterator<Item = T>,
F: FnMut(Drain<'_, (T, i64 )>) + 'static,

Creates a new token.

[src]

pub fn maybe_advance<F>(&mut self, frontier: F) where
F: IntoIterator<Item = T>,

Advance the frontier of the mutable antichain to frontier, if frontier is ahead of the current frontier.

This function intentionally does not assert that frontier will necessarily be in advance of the current frontier because some uses in the Coordinator don’t work well with that. Specifically, in the Coordinator its possible for a since frontier to be ahead of the upper frontier for an index, and changes to the upper frontier cause the Coordinator to want to “advance” the since to new_upper - logical_compaction_window which might not be in advance of the existing since frontier. TODO: can we remove maybe_advance and replace with a stricter advace that requires callers to present incresing frontiers?

Methods from Deref<Target = MutableAntichain<T>>

[src]

pub fn frontier(&self) -> AntichainRef<'_, T>

Reveals the minimal elements with positive count.

Examples

 use timely::progress::frontier::MutableAntichain;

 let mut frontier = MutableAntichain::<usize>::new();
 assert!(frontier.frontier().len() == 0);

[src]

pub fn is_empty(&self) -> bool

Returns true if there are no elements in the MutableAntichain.

Examples

 use timely::progress::frontier::MutableAntichain;

 let mut frontier = MutableAntichain::<usize>::new();
 assert!(frontier.is_empty());

[src]

pub fn less_than(&self, time: &T) -> bool where
T: PartialOrder,

Returns true if any item in the MutableAntichain is strictly less than the argument.

Examples

 use timely::progress::frontier::MutableAntichain;

 let mut frontier = MutableAntichain::new_bottom(1u64);
 assert!(!frontier.less_than(&0));
 assert!(!frontier.less_than(&1));
 assert!(frontier.less_than(&2));

[src]

pub fn less_equal(&self, time: &T) -> bool where
T: PartialOrder,

Returns true if any item in the MutableAntichain is less than or equal to the argument.

Examples

 use timely::progress::frontier::MutableAntichain;

 let mut frontier = MutableAntichain::new_bottom(1u64);
 assert!(!frontier.less_equal(&0));
 assert!(frontier.less_equal(&1));
 assert!(frontier.less_equal(&2));