wip

Author: ktoso

.gitignore

@@ -26,3 +26,4 @@ test-results
 test-tmp
 *.class
 gradle.properties
+*.orig

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

@@ -35,7 +35,7 @@ public static <T> org.reactivestreams.Publisher<T> toReactiveStreams(
             throw new NullPointerException("flowPublisher");
         }
         if (flowPublisher instanceof org.reactivestreams.Publisher) {
-            return (org.reactivestreams.Publisher<T>)flowPublisher;
+            return (org.reactivestreams.Publisher<T>) flowPublisher;
         }
         if (flowPublisher instanceof FlowPublisherFromReactive) {
             return (org.reactivestreams.Publisher<T>)(((FlowPublisherFromReactive<T>)flowPublisher).reactiveStreams);
@@ -57,7 +57,7 @@ public static <T> Flow.Publisher<T> toFlow(
             throw new NullPointerException("reactiveStreamsPublisher");
         }
         if (reactiveStreamsPublisher instanceof Flow.Publisher) {
-            return (Flow.Publisher<T>)reactiveStreamsPublisher;
+            return (Flow.Publisher<T>) reactiveStreamsPublisher;
         }
         if (reactiveStreamsPublisher instanceof ReactivePublisherFromFlow) {
             return (Flow.Publisher<T>)(((ReactivePublisherFromFlow<T>)reactiveStreamsPublisher).flow);
@@ -80,7 +80,7 @@ public static <T, U> org.reactivestreams.Processor<T, U> toReactiveStreams(
             throw new NullPointerException("flowProcessor");
         }
         if (flowProcessor instanceof org.reactivestreams.Processor) {
-            return (org.reactivestreams.Processor<T, U>)flowProcessor;
+            return (org.reactivestreams.Processor<T, U>) flowProcessor;
         }
         if (flowProcessor instanceof FlowToReactiveProcessor) {
             return (org.reactivestreams.Processor<T, U>)(((FlowToReactiveProcessor<T, U>)flowProcessor).reactiveStreams);
@@ -103,7 +103,7 @@ public static <T, U> Flow.Processor<T, U> toFlow(
             throw new NullPointerException("reactiveStreamsProcessor");
         }
         if (reactiveStreamsProcessor instanceof Flow.Processor) {
-            return (Flow.Processor<T, U>)reactiveStreamsProcessor;
+            return (Flow.Processor<T, U>) reactiveStreamsProcessor;
         }
         if (reactiveStreamsProcessor instanceof ReactiveToFlowProcessor) {
             return (Flow.Processor<T, U>)(((ReactiveToFlowProcessor<T, U>)reactiveStreamsProcessor).flow);
@@ -191,6 +191,7 @@ static final class FlowToReactiveSubscriber<T>
         private final org.reactivestreams.Subscriber<? super T> reactiveStreams;
 
         public FlowToReactiveSubscriber(org.reactivestreams.Subscriber<? super T> reactive) {
+            if (reactive == null) throw null;
             this.reactiveStreams = reactive;
         }
 
@@ -260,6 +261,7 @@ static final class ReactiveToFlowProcessor<T, U>
         final Flow.Processor<? super T, ? extends U> flow;
 
         public ReactiveToFlowProcessor(Flow.Processor<? super T, ? extends U> flow) {
+            if (flow == null) throw null;
             this.flow = flow;
         }