Fix java 6 syntax

Author: akarnokd

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

@@ -29,7 +29,7 @@ public static <T> org.reactivestreams.Publisher<T> toReactive(
         if (flowPublisher instanceof FlowPublisherFromReactive) {
             return (org.reactivestreams.Publisher<T>)(((FlowPublisherFromReactive<T>)flowPublisher).reactive);
         }
-        return new ReactivePublisherFromFlow<>(flowPublisher);
+        return new ReactivePublisherFromFlow<T>(flowPublisher);
     }
 
     /**
@@ -49,7 +49,7 @@ public static <T> Flow.Publisher<T> toFlow(
         if (reactivePublisher instanceof ReactivePublisherFromFlow) {
             return (Flow.Publisher<T>)(((ReactivePublisherFromFlow<T>)reactivePublisher).flow);
         }
-        return new FlowPublisherFromReactive<>(reactivePublisher);
+        return new FlowPublisherFromReactive<T>(reactivePublisher);
     }
 
     /**
@@ -70,7 +70,7 @@ public static <T, U> org.reactivestreams.Processor<T, U> toReactive(
         if (flowProcessor instanceof FlowToReactiveProcessor) {
             return (org.reactivestreams.Processor<T, U>)(((FlowToReactiveProcessor<T, U>)flowProcessor).reactive);
         }
-        return new ReactiveToFlowProcessor<>(flowProcessor);
+        return new ReactiveToFlowProcessor<T, U>(flowProcessor);
     }
 
     /**
@@ -91,7 +91,7 @@ public static <T, U> Flow.Processor<T, U> toFlow(
         if (reactiveProcessor instanceof ReactiveToFlowProcessor) {
             return (Flow.Processor<T, U>)(((ReactiveToFlowProcessor<T, U>)reactiveProcessor).flow);
         }
-        return new FlowToReactiveProcessor<>(reactiveProcessor);
+        return new FlowToReactiveProcessor<T, U>(reactiveProcessor);
     }
 
 
@@ -303,7 +303,7 @@ public void onComplete() {
 
         @Override
         public void subscribe(org.reactivestreams.Subscriber<? super U> s) {
-            flow.subscribe(new FlowToReactiveSubscriber<>(s));
+            flow.subscribe(new FlowToReactiveSubscriber<U>(s));
         }
     }
 
@@ -342,7 +342,7 @@ public void onComplete() {
 
         @Override
         public void subscribe(Flow.Subscriber<? super U> s) {
-            reactive.subscribe(new ReactiveToFlowSubscriber<>(s));
+            reactive.subscribe(new ReactiveToFlowSubscriber<U>(s));
         }
     }
 
@@ -360,7 +360,7 @@ public ReactivePublisherFromFlow(Flow.Publisher<? extends T> flowPublisher) {
 
         @Override
         public void subscribe(org.reactivestreams.Subscriber<? super T> reactive) {
-            flow.subscribe(new FlowToReactiveSubscriber<>(reactive));
+            flow.subscribe(new FlowToReactiveSubscriber<T>(reactive));
         }
     }
 
@@ -378,7 +378,7 @@ public FlowPublisherFromReactive(org.reactivestreams.Publisher<? extends T> reac
 
         @Override
         public void subscribe(Flow.Subscriber<? super T> flow) {
-            reactive.subscribe(new ReactiveToFlowSubscriber<>(flow));
+            reactive.subscribe(new ReactiveToFlowSubscriber<T>(flow));
         }
     }