in async/src/main/java/org/apache/geode_examples/async/Example.java [56:75]
public void checkWords(Region<Integer, String> incomingRegion,
Region<String, String> outgoingRegion, List<String> words) {
int key = 0;
for (String word : words) {
incomingRegion.put(key++, word);
}
// Give the process a chance to work.
while (outgoingRegion.sizeOnServer() < words.size()) {
try {
Thread.sleep(500);
} catch (InterruptedException ie) {
// NOP
}
}
for (String candidate : outgoingRegion.keySetOnServer()) {
System.out.println(candidate + " -> " + outgoingRegion.get(candidate));
}
}