boolean await(long duration, TimeUnit timeUnit) throws InterruptedException {
      return latch.await(duration, timeUnit);
    }
Waits until the all replicas receive the event.
@param duration the duration to wait for all the events to arrive
@param timeUnit the time unit of {@code duration}
@return {@code true} if events were received in all replicas within the {@code duration} specified.
@throws InterruptedException
ambry-test-utils/src/main/java/com/github/ambry/server/MockCluster.java