Example6.java

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class Example6 {

    public static void main(String[] args) throws InterruptedException, ExecutionException {
     CompletableFuture<String> basePrep = CompletableFuture.supplyAsync(() -> {
            System.out.println("Preparar Base");
            return "Base Lista!!!";
        });

        CompletableFuture<String> topPrep = CompletableFuture.supplyAsync(() -> {
            System.out.println("Agregar toppings");
            return "Toppings Listos!!!";
        });
        CompletableFuture<String> foodPrep = basePrep.thenCombine(topPrep,(baseResponse,topResponse) ->{
            System.out.println("Toppings y Base son::"+baseResponse+":"+topResponse);
            return "Pizza Lista!!!";
        });

        CompletableFuture<String> foodServe = foodPrep.thenCompose(food ->{
            System.out.println("Servir comida");
            return CompletableFuture.supplyAsync(()->"Comida servida");
        });
        CompletableFuture<String> order = foodServe.thenApply(orderComplete -> "Orden completa.."+orderComplete);
        try{
            System.out.println(order.get());
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}