Merge pull request java8#3 from jeffmorin/master

Technical proofing by Jean-François Morin

Author: raoulDoc

src/main/java/lambdasinaction/appa/Author.java

@@ -0,0 +1,13 @@
+package lambdasinaction.appa;
+
+import java.lang.annotation.Repeatable;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Repeatable(Authors.class)
+@Retention(RetentionPolicy.RUNTIME)
+public @interface Author {
+
+    String name();
+
+}

src/main/java/lambdasinaction/appa/Authors.java

@@ -0,0 +1,11 @@
+package lambdasinaction.appa;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.RUNTIME)
+public @interface Authors {
+
+    Author[] value();
+
+}

src/main/java/lambdasinaction/appa/Book.java

@@ -0,0 +1,17 @@
+package lambdasinaction.appa;
+
+import java.util.Arrays;
+
+@Author(name = "Raoul")
+@Author(name = "Mario")
+@Author(name = "Alan")
+public class Book {
+
+    public static void main(String[] args) {
+        Author[] authors = Book.class.getAnnotationsByType(Author.class);
+        Arrays.asList(authors).stream().forEach(a -> {
+            System.out.println(a.name());
+        });
+    }
+
+}

…/lambdasinaction/chap6/StreamForker.java …a/lambdasinaction/appc/StreamForker.javasrc/main/java/lambdasinaction/chap6/StreamForker.java renamed to src/main/java/lambdasinaction/appc/StreamForker.java src/main/java/lambdasinaction/chap6/StreamForker.java renamed to src/main/java/lambdasinaction/appc/StreamForker.java

@@ -1,4 +1,4 @@
-package lambdasinaction.chap6;
+package lambdasinaction.appc;
 
 import java.util.*;
 import java.util.concurrent.*;

…sinaction/chap6/StreamForkerExample.java …asinaction/appc/StreamForkerExample.javasrc/main/java/lambdasinaction/chap6/StreamForkerExample.java renamed to src/main/java/lambdasinaction/appc/StreamForkerExample.java src/main/java/lambdasinaction/chap6/StreamForkerExample.java renamed to src/main/java/lambdasinaction/appc/StreamForkerExample.java

@@ -1,4 +1,4 @@
-package lambdasinaction.chap6;
+package lambdasinaction.appc;
 
 import lambdasinaction.chap5.*;
 

src/main/java/lambdasinaction/appd/InnerClass.java

@@ -0,0 +1,12 @@
+package lambdasinaction.appd;
+
+import java.util.function.Function;
+
+public class InnerClass {
+    Function<Object, String> f = new Function<Object, String>() {
+        @Override
+        public String apply(Object obj) {
+            return obj.toString();
+        }
+    };
+}

src/main/java/lambdasinaction/appd/Lambda.java

@@ -0,0 +1,7 @@
+package lambdasinaction.appd;
+
+import java.util.function.Function;
+
+public class Lambda {
+    Function<Object, String> f = obj -> obj.toString();
+}

src/main/java/lambdasinaction/chap10/AsyncShop.java

@@ -1,10 +1,11 @@
 package lambdasinaction.chap10;
 
-import java.text.*;
-import java.util.*;
-import java.util.concurrent.*;
+import static lambdasinaction.chap10.Util.delay;
+import static lambdasinaction.chap10.Util.format;
 
-import static lambdasinaction.chap10.Util.*;
+import java.util.Random;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Future;
 
 public class AsyncShop {
 

src/main/java/lambdasinaction/chap10/AsyncShopClient.java

@@ -1,6 +1,6 @@
 package lambdasinaction.chap10;
 
-import java.util.concurrent.*;
+import java.util.concurrent.Future;
 
 public class AsyncShopClient {
 

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

@@ -1,8 +1,13 @@
 package lambdasinaction.chap10;
 
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.stream.*;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 public class BestPriceFinder {
 
@@ -20,68 +25,42 @@ public Thread newThread(Runnable r) {
             return t;
         }
     });
-/*
-    public List<String> findPriceSequential(String product) {
-        return shops.stream()
-                .map(shop -> shop.getName() + " price is " + shop.calculatePrice(product))
-                .collect(Collectors.toList());
-    }
-
-    public List<String> findPriceParallel(String product) {
-        return shops.parallelStream()
-                .map(shop -> shop.getName() + " price is " + shop.calculatePrice(product))
-                .collect(Collectors.toList());
-    }
-
-    public List<String> findPrice(String product) {
-        List<CompletableFuture<String>> priceFutures =
-                shops.stream()
-                .map(shop -> CompletableFuture.supplyAsync(() -> shop.getName() + " price is "
-                        + shop.calculatePrice(product), executor))
-                .collect(Collectors.toList());
 
-        List<String> prices = priceFutures.stream()
-                .map(CompletableFuture::join)
-                .collect(Collectors.toList());
-        return prices;
-        //return sequence(priceFutures).join();
-    }
-/*/
-    public List<String> findPriceSequential(String product) {
+    public List<String> findPricesSequential(String product) {
         return shops.stream()
                 .map(shop -> shop.getPrice(product))
                 .map(Quote::parse)
                 .map(Discount::applyDiscount)
                 .collect(Collectors.toList());
     }
 
-    public List<String> findPriceParallel(String product) {
+    public List<String> findPricesParallel(String product) {
         return shops.parallelStream()
                 .map(shop -> shop.getPrice(product))
                 .map(Quote::parse)
                 .map(Discount::applyDiscount)
                 .collect(Collectors.toList());
     }
 
-    public List<String> findPrice(String product) {
-        List<CompletableFuture<String>> priceFutures = findPriceStream(product)
+    public List<String> findPricesFuture(String product) {
+        List<CompletableFuture<String>> priceFutures = findPricesStream(product)
                 .collect(Collectors.<CompletableFuture<String>>toList());
 
         return priceFutures.stream()
                 .map(CompletableFuture::join)
                 .collect(Collectors.toList());
     }
 
-    public Stream<CompletableFuture<String>> findPriceStream(String product) {
+    public Stream<CompletableFuture<String>> findPricesStream(String product) {
         return shops.stream()
                 .map(shop -> CompletableFuture.supplyAsync(() -> shop.getPrice(product), executor))
                 .map(future -> future.thenApply(Quote::parse))
                 .map(future -> future.thenCompose(quote -> CompletableFuture.supplyAsync(() -> Discount.applyDiscount(quote), executor)));
     }
 
-    public void printPricesStream() {
+    public void printPricesStream(String product) {
         long start = System.nanoTime();
-        CompletableFuture[] futures = findPriceStream("myPhone")
+        CompletableFuture[] futures = findPricesStream(product)
                 .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();