in graphql-dgs-example-shared/src/main/java/com/netflix/graphql/dgs/example/shared/datafetcher/ConcurrentDataFetcher.java [50:67]
public CompletableFuture<Integer> concurrent2() {
System.out.println("Entry concurrent2");
CompletableFuture<Integer> stringCompletableFuture = CompletableFuture.supplyAsync(() -> {
try {
TimeUnit.MILLISECONDS.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Done concurrent thing 2");
return Long.valueOf(System.currentTimeMillis()).intValue();
});
System.out.println("Exit concurrent2");
return stringCompletableFuture;
}