Function mz_storage::upsert::rehydration_finished

pub fn rehydration_finished<G, T>(
    scope: G,
    source_config: &RawSourceCreationConfig,
    token: impl Any + 'static,
    resume_upper: Antichain<T>,
    input: &Stream<G, Infallible>,
)
where
    G: Scope<Timestamp = T>,
    T: Timestamp,

This leaf operator drops token after the input reaches the resume_upper. This is useful to take coordinated actions across all workers, after the upsert operator has rehydrated.