Trait mz_timely_util::probe::ProbeNotify

pub trait ProbeNotify<G: Scope> {
    // Required method
    fn probe_notify_with(&self, handles: Vec<Handle<G::Timestamp>>) -> Self;
}

Monitors progress at a Stream.

Required Methods

fn probe_notify_with(&self, handles: Vec<Handle<G::Timestamp>>) -> Self

Inserts a collection of progress probe in a stream.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<G, C> ProbeNotify<G> for StreamCore<G, C>

where G: Scope, C: Container + Data,

fn probe_notify_with(&self, handles: Vec<Handle<G::Timestamp>>) -> Self

Implementors