pub fn maybe_progress(&self, frontier: AntichainRef<u64>) {
        if let Ok(mut core) = self.core.lock() {
            core.maybe_progress(frontier)
        }
    }
/// Advance the internal frontier and unblock any relevant waiters.
///
/// This is intended to be called in the dataflow step loop:
///
/// ```
/// let (progress_tx, progress_rx) = DataflowProgress::new();
/// ...
/// timely::execute(
///     timely::Config::process(workers),
///     move |worker| {
///         let dataflow_read = dataflow_read.clone();
///         let mut probe = ProbeHandle::new();
///         worker.dataflow(|scope| {
///             let out = ...;
///             out.probe_with(&mut probe);
///         })
///         while worker.step_or_park(None) {
///             probe.with_frontier(|frontier| {
///                 progress_tx.maybe_progress(frontier);
///             })
///         }
///         progress_tx.close();
///     }
/// )
/// ```
Advance the internal frontier and unblock any relevant waiters.
This is intended to be called in the dataflow step loop.


Advance the internal frontier and unblock any relevant waiters . This is intended to be called in the dataflow step loop .
pub fn maybe_progress(&self, frontier: AntichainRef<u64>) {
        if let Ok(mut core) = self.core.lock() {
            core.maybe_progress(frontier)
        }
    }
pub fn maybe_progress ( & self , frontier : AntichainRef < u64 > ) { if let Ok ( mut core ) = self . core . lock ( ) { core . maybe_progress ( frontier ) } }
Advance the internal frontier and unblock any relevant waiters.
Advance the internal frontier and unblock any relevant waiters .
&self
frontier
AntichainRef<u64>
&self
frontier
AntichainRef<u64>