32 lines
838 B
Java
32 lines
838 B
Java
// concurrent/Baked.java
|
|
// (c)2020 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<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));
|
|
}
|
|
}
|