Flow-TCK is set up as Java 6 compile target

Author: akarnokd

tck-flow/src/test/java/org/reactivestreams/tck/flow/SubmissionPublisherTest.java

@@ -12,41 +12,46 @@
 package org.reactivestreams.tck.flow;
 
 import org.reactivestreams.tck.TestEnvironment;
+import org.testng.annotations.Test;
 
 import java.util.concurrent.*;
 
+@Test
 public class SubmissionPublisherTest extends FlowPublisherVerification<Integer> {
 
     public SubmissionPublisherTest() {
         super(new TestEnvironment());
     }
 
     @Override
-    public Flow.Publisher<Integer> createFlowPublisher(long elements) {
-        SubmissionPublisher<Integer> sp = new SubmissionPublisher<>();
-
-        ForkJoinPool.commonPool().submit(() -> {
-            while (sp.getNumberOfSubscribers() == 0) {
-                try {
-                    Thread.sleep(1);
-                } catch (InterruptedException ex) {
-                    return;
+    public Flow.Publisher<Integer> createFlowPublisher(final long elements) {
+        final SubmissionPublisher<Integer> sp = new SubmissionPublisher<Integer>();
+
+        ForkJoinPool.commonPool().submit(new Runnable() {
+            @Override
+            public void run() {
+                while (sp.getNumberOfSubscribers() == 0) {
+                    try {
+                        Thread.sleep(1);
+                    } catch (InterruptedException ex) {
+                        return;
+                    }
                 }
-            }
 
-            for (int i = 0; i < elements; i++) {
-                sp.submit(i);
-            }
+                for (int i = 0; i < elements; i++) {
+                    sp.submit(i);
+                }
 
-            sp.close();
+                sp.close();
+            }
         });
 
         return sp;
     }
 
     @Override
     public Flow.Publisher<Integer> createFailedFlowPublisher() {
-        SubmissionPublisher<Integer> sp = new SubmissionPublisher<>();
+        SubmissionPublisher<Integer> sp = new SubmissionPublisher<Integer>();
         sp.closeExceptionally(new Exception());
         return sp;
     }