risingwave_storage::hummock::utils

Function wait_for_update

source
pub(crate) async fn wait_for_update(
    notifier: &Sender<PinnedVersion>,
    inspect_fn: impl FnMut(&PinnedVersion) -> HummockResult<bool>,
    periodic_debug_info: impl FnMut() -> String,
) -> HummockResult<()>