public static void assertCounterSizes() {
    WaitCriterion ev = new WaitCriterion() {
      @Override
      public boolean done() {
        return counterCreate == 2;
      }

      @Override
      public String description() {
        return "Expected counterCreate to be 2. Instead it was " + counterCreate + ".";
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);

    ev = new WaitCriterion() {
      @Override
      public boolean done() {
        return counterUpdate == 2;
      }

      @Override
      public String description() {
        return "Expected counterUpdate to be 2. Instead it was " + counterUpdate + ".";
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);

    ev = new WaitCriterion() {
      @Override
      public boolean done() {
        return counterDestroy == 2;
      }

      @Override
      public String description() {
        return "Expected counterDestroy to be 2. Instead it was " + counterDestroy + ".";
      }
    };
    GeodeAwaitility.await().untilAsserted(ev);
  }
assert the counters size are as expected (2)
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ConflationDistributedTest.java