boolean awaitBlobUpdates(UpdateType updateType) throws InterruptedException {
    return updateHelpers.computeIfAbsent(updateType, type -> new Helper(numberOfReplicas))
        .await(WAIT_SECONDS, TimeUnit.SECONDS);
  }
Waits for blob updates of type {@code updateType} on all replicas
@param updateType the type of update to wait for
@return {@code true} if updates of type {@code updateType} were received in all replicas within the
{@code duration} specified.
@throws InterruptedException
ambry-test-utils/src/main/java/com/github/ambry/server/MockCluster.java