OnJava8-Examples/concurrent/Baked.java at master · CSapprenticeWT/OnJava8-Examples · GitHub

Repository navigation

// concurrent/Baked.java

// 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<Baked>

bake(CompletableFuture<Batter> cfb) {

return cfb

.thenApplyAsync(Baked::pan)

.thenApplyAsync(Baked::heat);

}

public static

Stream<CompletableFuture<Baked>> batch() {

CompletableFuture<Batter> batter = Batter.mix();

return Stream.of(bake(batter), bake(batter),

bake(batter), bake(batter));

}