Trait mz_timely_util::activator::ActivatorTrait

source · 
pub trait ActivatorTrait {
    // Required methods
    fn activate(&self);
    fn ack(&self);
    fn register<S: Scope>(&self, scope: &mut S, path: &[usize]);
}
Expand description

Generic activator behavior

Required Methods§

source

fn activate(&self)

Trigger an activation of operators behind this activator.

source

fn ack(&self)

Acknowledge the receipt of activations from within an operator.

source

fn register<S: Scope>(&self, scope: &mut S, path: &[usize])

Register a new operator with its path with this activator.

Object Safety§

This trait is not object safe.

Implementors§