Add JDK9 TCK, using adapters

Author: ktoso

.java-version

@@ -0,0 +1 @@
+9

build.gradle

@@ -46,7 +46,11 @@ subprojects {
         }
     }
 
-    if (name in ["reactive-streams", "reactive-streams-tck", "reactive-streams-examples", "reactive-streams-flow-bridge"]) {
+    if (name in ["reactive-streams", 
+                 "reactive-streams-tck", 
+                 "reactive-streams-tck-flow",
+                 "reactive-streams-examples",
+                 "reactive-streams-flow-bridge"]) {
         apply plugin: "maven"
         apply plugin: "signing"
 

flow-bridge/src/main/java/org/reactivestreams/ReactiveStreamsFlowBridge.java

@@ -64,7 +64,7 @@ public static <T> Flow.Publisher<T> toFlow(
         }
         return new FlowPublisherFromReactive<T>(reactiveStreamsPublisher);
     }
-    
+
     /**
      * Converts a Flow Processor into a Reactive Streams Processor.
      * @param <T> the input value type
@@ -117,7 +117,7 @@ public static <T, U> Flow.Processor<T, U> toFlow(
      * @param reactiveStreamsSubscriber the Reactive Streams Subscriber instance to convert
      * @return the equivalent Flow Subscriber
      */
-    public static <T> Flow.Subscriber<T> toFlowSubscriber(org.reactivestreams.Subscriber<T> reactiveStreamsSubscriber) {
+    public static <T> Flow.Subscriber<T> toFlow(org.reactivestreams.Subscriber<T> reactiveStreamsSubscriber) {
         if (reactiveStreamsSubscriber == null) {
             throw new NullPointerException("reactiveStreamsSubscriber");
         }
@@ -130,7 +130,7 @@ public static <T> Flow.Subscriber<T> toFlowSubscriber(org.reactivestreams.Subscr
      * @param flowSubscriber the Flow Subscriber instance to convert
      * @return the equivalent Reactive Streams Subscriber
      */
-    public static <T> org.reactivestreams.Subscriber<T> toReactiveStreamsSubscriber(Flow.Subscriber<T> flowSubscriber) {
+    public static <T> org.reactivestreams.Subscriber<T> toReactiveStreams(Flow.Subscriber<T> flowSubscriber) {
         if (flowSubscriber == null) {
             throw new NullPointerException("flowSubscriber");
         }
@@ -142,7 +142,7 @@ public static <T> org.reactivestreams.Subscriber<T> toReactiveStreamsSubscriber(
      */
     static final class FlowToReactiveSubscription implements Flow.Subscription {
         private final org.reactivestreams.Subscription reactiveStreams;
-        
+
         public FlowToReactiveSubscription(org.reactivestreams.Subscription reactive) {
             this.reactiveStreams = reactive;
         }
@@ -156,15 +156,15 @@ public void request(long n) {
         public void cancel() {
             reactiveStreams.cancel();
         }
-        
+
     }
-    
+
     /**
      * Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.
      */
     static final class ReactiveToFlowSubscription implements org.reactivestreams.Subscription {
         private final Flow.Subscription flow;
-        
+
         public ReactiveToFlowSubscription(Flow.Subscription flow) {
             this.flow = flow;
         }
@@ -178,18 +178,18 @@ public void request(long n) {
         public void cancel() {
             flow.cancel();
         }
-        
-        
+
+
     }
-    
+
     /**
      * Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
      * @param <T> the element type
      */
-    static final class FlowToReactiveSubscriber<T> 
+    static final class FlowToReactiveSubscriber<T>
             implements Flow.Subscriber<T> {
         private final org.reactivestreams.Subscriber<? super T> reactiveStreams;
-        
+
         public FlowToReactiveSubscriber(org.reactivestreams.Subscriber<? super T> reactive) {
             this.reactiveStreams = reactive;
         }
@@ -213,17 +213,17 @@ public void onError(Throwable throwable) {
         public void onComplete() {
             reactiveStreams.onComplete();
         }
-        
+
     }
 
     /**
      * Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
      * @param <T> the element type
      */
-    static final class ReactiveToFlowSubscriber<T> 
+    static final class ReactiveToFlowSubscriber<T>
             implements org.reactivestreams.Subscriber<T> {
         private final Flow.Subscriber<? super T> flow;
-        
+
         public ReactiveToFlowSubscriber(Flow.Subscriber<? super T> flow) {
             this.flow = flow;
         }
@@ -247,9 +247,9 @@ public void onError(Throwable throwable) {
         public void onComplete() {
             flow.onComplete();
         }
-        
+
     }
-    
+
     /**
      * Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
      * @param <T> the input type
@@ -258,7 +258,7 @@ public void onComplete() {
     static final class ReactiveToFlowProcessor<T, U>
             implements org.reactivestreams.Processor<T, U> {
         final Flow.Processor<? super T, ? extends U> flow;
-        
+
         public ReactiveToFlowProcessor(Flow.Processor<? super T, ? extends U> flow) {
             this.flow = flow;
         }
@@ -292,7 +292,7 @@ public void subscribe(org.reactivestreams.Subscriber<? super U> s) {
             flow.subscribe(new FlowToReactiveSubscriber<U>(s));
         }
     }
-    
+
     /**
      * Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
      * @param <T> the input type
@@ -301,7 +301,7 @@ public void subscribe(org.reactivestreams.Subscriber<? super U> s) {
     static final class FlowToReactiveProcessor<T, U>
             implements Flow.Processor<T, U> {
         final org.reactivestreams.Processor<? super T, ? extends U> reactiveStreams;
-        
+
         public FlowToReactiveProcessor(org.reactivestreams.Processor<? super T, ? extends U> reactive) {
             this.reactiveStreams = reactive;
         }
@@ -380,4 +380,4 @@ public void subscribe(Flow.Subscriber<? super T> flow) {
         }
     }
 
-}
+}