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

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

Reports information about progress at the probe.

Implementations

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.

impl<T: Debug + Timestamp> Debug for Handle<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Handle<T>

where T: Timestamp,

fn default() -> Self

Returns the “default value” for a type.