jadex.java

public IIntermediateFuture<ThingDescription> discover() {
  IntermediateFuture<ThingDescription> result = new IntermediateFuture<>();
  // get all persistence services
  AtomicInteger ai = new AtomicInteger();
  ITerminableIntermediateFuture<PersistenceService> services = this.agent.getFeature(IRequiredServicesFeature.class).getServices(“PersistenceService");
  services.addIntermediateResultListener(service -> {
      ai.incrementAndGet();
      // get all thing descriptions of this service
      IIntermediateFuture<ThingDescription> thingDescriptions = service.getAllObjects(ThingDescription.class);
      thingDescriptions.addIntermediateResultListener(thingDescription -> {
      	  // add thing description to result
          System.out.println("addIntermediateResult");
          result.addIntermediateResult(thingDescription);
      }, () -> {
          if (ai.decrementAndGet() < 1) {
            result.setFinished();
          }
      }, e -> {
          if (ai.decrementAndGet() < 1) {
             result.setFinished();
          }
  });
  }, () -> {
      // all thing descriptions of all services collected -> mark as finished
      System.out.println("setFinished”);
      result.setFinished();
  });

  return result;
}