// concurrent/Baked.java // (c)2017 MindView LLC: see Copyright.txt // We make no guarantees that this code is fit for any purpose. // Visit http://OnJava8.com for more book information. import java.util.concurrent.*; import java.util.stream.*; import onjava.Nap; public class Baked { static class Pan {} static Pan pan(Batter b) { new Nap(0.1); return new Pan(); } static Baked heat(Pan p) { new Nap(0.1); return new Baked(); } static CompletableFuture bake(CompletableFuture cfb) { return cfb .thenApplyAsync(Baked::pan) .thenApplyAsync(Baked::heat); } public static Stream> batch() { CompletableFuture batter = Batter.mix(); return Stream.of(bake(batter), bake(batter), bake(batter), bake(batter)); } }