private void verifyConflationIndexesSize(String senderId, int expectedSize, VM... vms) {
    await().untilAsserted(() -> {
      int actualSize = 0;
      for (VM vm : vms) {
        List<Integer> stats = vm.invoke(() -> WANTestBase.getSenderStats(senderId, -1));
        actualSize += stats.get(9);
      }
      assertThat(actualSize).isEqualTo(expectedSize);
    });
  }
1 region and sender configured on local site and 1 region and a receiver configured on remote
site. Puts to the local region are in progress. Remote region is destroyed in the middle.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDistributedTest.java