Trait 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.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so 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