Merge pull request #91 from ktoso/bring-back-TCK-ktoso

Bring back TCK for 0.4.0

Author: smaldini

Diff for: .travis.yml

@@ -0,0 +1,3 @@
+language: java
+script: sbt test
+

Diff for: README.md

@@ -35,7 +35,7 @@ public static synchronized void addHandler(Handler handler) {
 
     public static synchronized void removeHandler(Handler handler) {
         // too lazy to do the array handling
-        HashSet<Handler> set = new HashSet<>(Arrays.asList(INSTANCE.handlers));
+        HashSet<Handler> set = new HashSet<Handler>(Arrays.asList(INSTANCE.handlers));
         set.remove(handler);
         INSTANCE.handlers = set.toArray(new Handler[set.size()]);
     }

Diff for: api/src/examples/java/org/reactivestreams/example/multicast/NeverEndingStockStream.java

@@ -13,7 +13,7 @@ public class StockPriceSubscriber implements Subscriber<Stock> {
     private final int take;
 
     public StockPriceSubscriber(int bufferSize, int delayPerStock, int take) {
-        this.buffer = new ArrayBlockingQueue<>(bufferSize);
+        this.buffer = new ArrayBlockingQueue<Stock>(bufferSize);
         this.delayPerStock = delayPerStock;
         this.take = take;
     }

Diff for: api/src/examples/java/org/reactivestreams/example/multicast/StockPriceSubscriber.java

@@ -1,6 +1,5 @@
 package org.reactivestreams.example.unicast;
 
-import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 
 import org.reactivestreams.Subscription;

Diff for: api/src/examples/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java

@@ -8,7 +8,7 @@
 class NumberSubscriberThatHopsThreads implements Subscriber<Integer> {
 
     final int BUFFER_SIZE = 10;
-    private final ArrayBlockingQueue<Integer> buffer = new ArrayBlockingQueue<>(BUFFER_SIZE);
+    private final ArrayBlockingQueue<Integer> buffer = new ArrayBlockingQueue<Integer>(BUFFER_SIZE);
     private volatile boolean terminated = false;
     private final String token;