vichu

@SpringBootApplication
@EnableIntegrationGraphController(allowedOrigins = "http://localhost:8082")
public class Application {

  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }

}

vichu

ForkJoinPool myThreadPool = new ForkJoinPool(10);

CompletableFuture<Integer> myCompletableFutureInt = CompletableFuture.supplyAsync(() -> {
  try {
    int sleepTime = new Random().nextInt(2000);
    Thread.sleep(sleepTime);
    System.out.println(
        "Sleeping for " + sleepTime + " in myCompletableFutureInt on thread "
            + Thread.currentThread().getName());
  } catch (InterruptedException e) {

vichu

CompletableFuture<CompletableFuture<CompletableFuture<Map<String, Object>>>> result = myCompletableFutureBigDecimal.thenApply(bigDecimal ->
    myCompletableFutureInt.thenApply( integer ->
        myCompletableFutureLong.thenApply(aLong -> {
          Map<String, Object> objectHashMap = new HashMap<>();
          objectHashMap.put("IntegerValue", integer);
          objectHashMap.put("LongValue", aLong);
          objectHashMap.put("BigDecimalValue", bigDecimal);
          return objectHashMap;
        })));

vichu

CompletableFuture<Map<String, Object>> myObjectCompletableFuture =
    myCompletableFutureBigDecimal.thenCompose(bigDecimalValue ->
        myCompletableFutureInt
            .thenCombine(myCompletableFutureLong,
                ((integerValue, longValue) -> {
                  Map<String, Object> objectHashMap = new HashMap<>();
                  objectHashMap.put("IntegerValue", integerValue);
                  objectHashMap.put("LongValue", longValue);
                  objectHashMap.put("BigDecimalValue", bigDecimalValue);
                  return objectHashMap;

vichu

try {
  Map<String, Object> myObjectMap = myObjectCompletableFuture.get(2, TimeUnit.SECONDS);
  myObjectMap.entrySet().forEach(stringObjectEntry -> System.out
      .println(stringObjectEntry.getKey() + " = " + stringObjectEntry.getValue().toString()));
} catch (InterruptedException | ExecutionException | TimeoutException e) {
  e.printStackTrace();
}

vichu

<modules>
    <module>maven-reactor-app</module>
    <module>maven-reactor-util</module>
</modules>

vichu

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.indywiz.springorama.reactor</groupId>
    <artifactId>maven-reactor-parent</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

vichu

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <parent>
    <artifactId>maven-reactor-parent</artifactId>
    <groupId>com.indywiz.springorama.reactor</groupId>
    <version>1.0-SNAPSHOT</version>
  </parent>

vichu

<dependency>
  <groupId>com.indywiz.springorama.reactor</groupId>
  <artifactId>maven-reactor-util</artifactId>
  <version>1.0-SNAPSHOT</version>
</dependency>

vichu

<modules>
    <module>maven-reactor-app</module>
    <module>maven-reactor-util</module>
</modules>