private void validateEventCountAtClient() {
    await()
        .untilAsserted(() -> verify(spyCacheListener, times(PUT_COUNT)).afterCreate(any()));
  }
Waits for the listener to receive all events
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARegionQueueExpiryRegressionDistributedTest.java