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