Function mz_timely_util::probe::source

pub fn source<G, T>(
    scope: G,
    name: String,
    handle: Handle<T>
) -> Stream<G, Infallible>
where
    G: Scope<Timestamp = T>,
    T: Timestamp,

Creates a stream that flows progress updates from a probe.

The returned stream is guaranteed to never yield any data updates, as is reflected by its type.