Struct timely::dataflow::operators::probe::Handle
[−]
[src]
pub struct Handle<T: Timestamp> { /* fields omitted */ }
Reports information about progress at the probe.
Methods
impl<T: Timestamp> Handle<T>
[src]
pub fn less_than(&self, time: &T) -> bool
[src]
returns true iff the frontier is strictly less than time
.
pub fn less_equal(&self, time: &T) -> bool
[src]
returns true iff the frontier is less than or equal to time
.
pub fn done(&self) -> bool
[src]
returns true iff the frontier is empty.
pub fn new() -> Self
[src]
Allocates a new handle.
pub fn with_frontier<R, F: FnMut(&[T]) -> R>(&self, function: F) -> R
[src]
Invokes a method on the frontier, returning its result.
This method allows inspection of the frontier, which cannot be returned by reference as
it is on the other side of a RefCell
.
#Examples
use timely::dataflow::operators::probe::Handle; let handle = Handle::<usize>::new(); let frontier = handle.with_frontier(|frontier| frontier.to_vec());