public static void assertCounterSizesLessThan200() {
    WaitCriterion ev = new WaitCriterion() {
      @Override
      public boolean done() {
        Thread.yield(); // TODO is this necessary?
        return counterCreate == 2;
      }

      @Override
      public String description() {
        return null;
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);
    // assertIndexDetailsEquals("creates", 2, counterCreate);

    ev = new WaitCriterion() {
      @Override
      public boolean done() {
        Thread.yield(); // TODO is this necessary?
        return counterDestroy == 2;
      }

      @Override
      public String description() {
        return null;
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);

    ev = new WaitCriterion() {
      @Override
      public boolean done() {
        Thread.yield(); // TODO is this necessary?
        return counterUpdate <= 200;
      }

      @Override
      public String description() {
        return null;
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);
  }
assert the counters size less than 20000
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ConflationDistributedTest.java