private void waitForIndexedBuckets(final PartitionedIndex index, final int bucketCount) {
    await().until(() -> index.getNumberOfIndexedBuckets() >= bucketCount);
  }
Creates async indexes and compares the results between index and non-index results.
geode-core/src/distributedTest/java/org/apache/geode/cache/query/dunit/QueryIndexUsingXMLDUnitTest.java