pub async fn wait_caught_up(
runs: &[&ProjectionRun],
) -> Result<(), CaughtUpError>Expand description
Waits until every given run has caught up, as a service does before it takes requests. A run that has caught up once counts, even if it has ended since. Dropping the future stops waiting.
ยงErrors
Fails as soon as one of the runs has ended before it caught up: with the failure of the first run among the given ones that ended with one, and otherwise, if a run stopped because its token was cancelled, naming the first of those.