reactive CompletableFuture

Author: mariofusco

src/main/java/lambdasinaction/chap10/BestPriceFinder.java

@@ -78,4 +78,12 @@ public Stream<CompletableFuture<String>> findPriceStream(String product) {
                 .map(future -> future.thenApply(Quote::parse))
                 .map(future -> future.thenCompose(quote -> CompletableFuture.supplyAsync(() -> Discount.applyDiscount(quote), executor)));
     }
+
+    public void printPricesStream() {
+        long start = System.nanoTime();
+        CompletableFuture[] futures = findPriceStream("myPhone")
+                .map(f -> f.thenAccept(s -> System.out.println(s + " (done in " + ((System.nanoTime() - start) / 1_000_000) + " msecs)")))
+                .toArray(size -> new CompletableFuture[size]);
+        CompletableFuture.allOf(futures).join();
+    }
 }

src/main/java/lambdasinaction/chap10/BestPriceFinderMain.java

@@ -14,17 +14,7 @@ public static void main(String[] args) {
         //execute("sequential", () -> bestPriceFinder.findPriceSequential("myPhone"));
         //execute("parallel", () -> bestPriceFinder.findPriceParallel("myPhone"));
         //execute("composed CompletableFuture", () -> bestPriceFinder.findPrice("myPhone"));
-        printPricesStream();
-    }
-
-    private static void printPricesStream() {
-        long start = System.nanoTime();
-        List<CompletableFuture<Void>> futures =
-        bestPriceFinder.findPriceStream("myPhone")
-                       .map(f -> f.thenAccept(s -> System.out.println(s + " (find in " + ((System.nanoTime() - start) / 1_000_000) + " msecs)")))
-                       .collect(toList());
-
-        CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()])).join();
+        bestPriceFinder.printPricesStream();
     }
 
     private static void execute(String msg, Supplier<List<String>> s) {