public void checkWords()

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));
    }
  }