Struct timely::dataflow::operators::probe::Handle

pub struct Handle<T: Timestamp> { /* fields omitted */ }

Reports information about progress at the probe.

Methods

impl<T: Timestamp> Handle<T>

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

returns true iff the frontier is strictly less than time.

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

returns true iff the frontier is less than or equal to time.

pub fn done(&self) -> bool

returns true iff the frontier is empty.

pub fn new() -> Self

Allocates a new handle.

pub fn with_frontier<R, F: FnMut(AntichainRef<T>) -> R>(&self, function: F) -> R

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

Trait Implementations

impl<T: Timestamp> Clone for Handle<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.