public boolean processEvents()

in async/src/main/java/org/apache/geode_examples/async/ExampleAsyncEventListener.java [53:65]

• 13 lines of code
• 2 McCabe index (conditional complexity)

  public boolean processEvents(List<AsyncEvent> events) {
    final ExecutorService exService = Executors.newSingleThreadExecutor();
    for (AsyncEvent<Integer, String> event : events) {
      final String oldValue = event.getDeserializedValue();
      final String newValue = spellCheck(oldValue);
      exService.submit(() -> {
        Cache cache = (Cache) event.getRegion().getRegionService();
        Region<String, String> region = cache.getRegion(Example.OUTGOING_REGION_NAME);
        region.put(oldValue, newValue);
      });
    }
    return true;
  }