use expliciti typing

Author: thomasnield

src/main/java/rx/javafx/sources/ObservableMapSource.java

@@ -28,7 +28,7 @@ public static <K,T> Observable<Entry<K,T>> fromObservableMapAdds(final Observabl
             MapChangeListener<K,T> listener = c -> {
 
                 if (c.wasAdded()) {
-                   subscriber.onNext(new SimpleEntry<>(c.getKey(),c.getValueAdded()));
+                   subscriber.onNext(new SimpleEntry<K,T>(c.getKey(),c.getValueAdded()));
                 }
 
             };
@@ -45,7 +45,7 @@ public static <K,T> Observable<Entry<K,T>> fromObservableMapRemovals(final Obser
             MapChangeListener<K,T> listener = c -> {
 
                 if (c.wasRemoved()) {
-                    subscriber.onNext(new SimpleEntry<>(c.getKey(),c.getValueRemoved()));
+                    subscriber.onNext(new SimpleEntry<K,T>(c.getKey(),c.getValueRemoved()));
                 }
 
             };
@@ -62,10 +62,10 @@ public static <K,T> Observable<MapChange<K,T>> fromObservableMapChanges(final Ob
             MapChangeListener<K,T> listener = c -> {
 
                 if (c.wasRemoved()) {
-                    subscriber.onNext(new MapChange<>(c.getKey(),c.getValueRemoved(),Flag.REMOVED));
+                    subscriber.onNext(new MapChange<K,T>(c.getKey(),c.getValueRemoved(),Flag.REMOVED));
                 }
                 if (c.wasAdded()) {
-                    subscriber.onNext(new MapChange<>(c.getKey(),c.getValueAdded(),Flag.ADDED));
+                    subscriber.onNext(new MapChange<K,T>(c.getKey(),c.getValueAdded(),Flag.ADDED));
                 }
 
             };

src/main/java/rx/javafx/sources/ObservableSetSource.java

@@ -54,10 +54,10 @@ public static <T> Observable<SetChange<T>> fromObservableSetChanges(final Observ
 
             SetChangeListener<T> listener = c -> {
                 if (c.wasRemoved()) {
-                    subscriber.onNext(new SetChange<>(c.getElementRemoved(), Flag.REMOVED));
+                    subscriber.onNext(new SetChange<T>(c.getElementRemoved(), Flag.REMOVED));
                 }
                 if (c.wasAdded()) {
-                    subscriber.onNext(new SetChange<>(c.getElementAdded(), Flag.ADDED));
+                    subscriber.onNext(new SetChange<T>(c.getElementAdded(), Flag.ADDED));
                 }
             };
             source.addListener(listener);