fn maybe_update_progress(&mut self, latest_update_ts: &Timestamp) {
        if *latest_update_ts > self.latest_progress_ts {
            self.latest_progress_ts = *latest_update_ts;
        }
    }
/// Updates the latest progress update timestamp to `latest_update_ts` if it
/// is greater than the currently maintained timestamp.
///
/// This does not emit a progress update and should be used when the sink
/// emits a progress update that is not based on updates of the input
/// frontier.
///
/// See [`maybe_emit_progress`](Self::maybe_emit_progress).
Updates the latest progress update timestamp to `latest_update_ts` if it
is greater than the currently maintained timestamp.

This does not emit a progress update and should be used when the sink
emits a progress update that is not based on updates of the input
frontier.


Updates the latest progress update timestamp to ` latest_update_ts ` if it is greater than the currently maintained timestamp . This does not emit a progress update and should be used when the sink emits a progress update that is not based on updates of the input frontier .
fn maybe_update_progress(&mut self, latest_update_ts: &Timestamp) {
        if *latest_update_ts > self.latest_progress_ts {
            self.latest_progress_ts = *latest_update_ts;
        }
    }
fn maybe_update_progress ( & mut self , latest_update_ts : & Timestamp ) { if * latest_update_ts > self . latest_progress_ts { self . latest_progress_ts = * latest_update_ts ; } }
Updates the latest progress update timestamp to `latest_update_ts` if it
is greater than the currently maintained timestamp.
Updates the latest progress update timestamp to ` latest_update_ts ` if it is greater than the currently maintained timestamp .
&mut self
latest_update_ts
&Timestamp
&mut self
latest_update_ts
&Timestamp